1 18 package org.apache.activemq.command; 19 20 import org.apache.activemq.state.CommandVisitor; 21 22 27 public class SessionInfo extends BaseCommand { 28 29 public static final byte DATA_STRUCTURE_TYPE=CommandTypes.SESSION_INFO; 30 31 protected SessionId sessionId; 32 33 public SessionInfo() { 34 sessionId = new SessionId(); 35 } 36 37 public SessionInfo(ConnectionInfo connectionInfo, long sessionId) { 38 this.sessionId = new SessionId(connectionInfo.getConnectionId(), sessionId); 39 } 40 41 public SessionInfo(SessionId sessionId) { 42 this.sessionId = sessionId; 43 } 44 45 public byte getDataStructureType() { 46 return DATA_STRUCTURE_TYPE; 47 } 48 49 52 public SessionId getSessionId() { 53 return sessionId; 54 } 55 public void setSessionId(SessionId sessionId) { 56 this.sessionId = sessionId; 57 } 58 59 public RemoveInfo createRemoveCommand() { 60 RemoveInfo command = new RemoveInfo(getSessionId()); 61 command.setResponseRequired(isResponseRequired()); 62 return command; 63 } 64 65 public Response visit(CommandVisitor visitor) throws Exception { 66 return visitor.processAddSession( this); 67 } 68 69 } 70 | Popular Tags |