SessionInfo


1   /**
2    *
3    * Licensed to the Apache Software Foundation (ASF) under one or more
4    * contributor license agreements.  See the NOTICE file distributed with
5    * this work for additional information regarding copyright ownership.
6    * The ASF licenses this file to You under the Apache License, Version 2.0
7    * (the "License"); you may not use this file except in compliance with
8    * the License.  You may obtain a copy of the License at
9    *
10   * http://www.apache.org/licenses/LICENSE-2.0
11   *
12   * Unless required by applicable law or agreed to in writing, software
13   * distributed under the License is distributed on an "AS IS" BASIS,
14   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15   * See the License for the specific language governing permissions and
16   * limitations under the License.
17   */
18  package org.apache.activemq.command;
19  
20  import org.apache.activemq.state.CommandVisitor;
21  
22  /**
23   * 
24   * @openwire:marshaller code="4"
25   * @version $Revision: 1.13 $
26   */
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      /**
50       * @openwire:property version=1 cache=true
51       */
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
A to Z: JavaDoc & Examples Daily Java News & Articles Open Source Projects Open Source Codes Free Computer Books Remove Frame
Free Books Free Magazines
Popular Tags