View Javadoc

1   /*** 
2    * 
3    * Copyright 2004 Protique Ltd
4    * 
5    * Licensed under the Apache License, Version 2.0 (the "License"); 
6    * you may not use this file except in compliance with the License. 
7    * You may obtain a copy of the License at 
8    * 
9    * http://www.apache.org/licenses/LICENSE-2.0
10   * 
11   * Unless required by applicable law or agreed to in writing, software
12   * distributed under the License is distributed on an "AS IS" BASIS, 
13   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 
14   * See the License for the specific language governing permissions and 
15   * limitations under the License. 
16   * 
17   **/
18  
19  package org.codehaus.activemq.message;
20  
21  /***
22   * Denotes life cycle infomation for a Producer of messages
23   */
24  
25  public class ProducerInfo extends AbstractPacket {
26      private ActiveMQDestination destination;
27      private String producerId;
28      private String clientId;
29      private String sessionId;
30      private long startTime;
31      private boolean started;
32  
33  
34      /***
35       * Test for equality
36       *
37       * @param obj object to test
38       * @return true if equivalent
39       */
40      public boolean equals(Object obj) {
41          boolean result = false;
42          if (obj != null && obj instanceof ProducerInfo) {
43              ProducerInfo info = (ProducerInfo) obj;
44              result = this.producerId == info.producerId;
45          }
46          return result;
47      }
48  
49      /***
50       * @return hash code for instance
51       */
52      public int hashCode() {
53          return this.producerId != null ? this.producerId.hashCode() : super.hashCode();
54      }
55  
56  
57      /***
58       * @return Returns the producerId.
59       */
60      public String getProducerId() {
61          return producerId;
62      }
63  
64      /***
65       * @param producerId The producerId to set.
66       */
67      public void setProducerId(String producerId) {
68          this.producerId = producerId;
69      }
70  
71      /***
72       * @return Returns the sessionId.
73       */
74      public String getSessionId() {
75          return sessionId;
76      }
77  
78      /***
79       * @param sessionId The sessionId to set.
80       */
81      public void setSessionId(String sessionId) {
82          this.sessionId = sessionId;
83      }
84  
85      /***
86       * Return the type of Packet
87       *
88       * @return integer representation of the type of Packet
89       */
90  
91      public int getPacketType() {
92          return PRODUCER_INFO;
93      }
94  
95  
96      /***
97       * @return Returns the clientId.
98       */
99      public String getClientId() {
100         return this.clientId;
101     }
102 
103     /***
104      * @param newClientId The clientId to set.
105      */
106     public void setClientId(String newClientId) {
107         this.clientId = newClientId;
108     }
109 
110 
111     /***
112      * @return Returns the destination.
113      */
114     public ActiveMQDestination getDestination() {
115         return this.destination;
116     }
117 
118     /***
119      * @param newDestination The destination to set.
120      */
121     public void setDestination(ActiveMQDestination newDestination) {
122         this.destination = newDestination;
123     }
124 
125 
126     /***
127      * @return Returns the started.
128      */
129     public boolean isStarted() {
130         return this.started;
131     }
132 
133     /***
134      * @param flag to indicate if started
135      */
136     public void setStarted(boolean flag) {
137         this.started = flag;
138     }
139 
140     /***
141      * @return Returns the startTime.
142      */
143     public long getStartTime() {
144         return this.startTime;
145     }
146 
147     /***
148      * @param newStartTime The startTime to set.
149      */
150     public void setStartTime(long newStartTime) {
151         this.startTime = newStartTime;
152     }
153 }