KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > apache > activemq > command > CommandTypes


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 /**
21  * Holds the command id constants used by the command objects.
22  *
23  * @version $Revision: 1.21 $
24  */
25 public interface CommandTypes {
26     
27     // What is the latest version of the openwire protocol
28 byte PROTOCOL_VERSION = 3;
29
30     // A marshaling layer can use this type to specify a null object.
31 byte NULL = 0;
32
33     ///////////////////////////////////////////////////
34 //
35 // Info objects sent back and forth client/server when
36 // setting up a client connection.
37 //
38 ///////////////////////////////////////////////////
39 byte WIREFORMAT_INFO = 1;
40     byte BROKER_INFO = 2;
41     byte CONNECTION_INFO = 3;
42     byte SESSION_INFO = 4;
43     byte CONSUMER_INFO = 5;
44     byte PRODUCER_INFO = 6;
45     byte TRANSACTION_INFO = 7;
46     byte DESTINATION_INFO = 8;
47     byte REMOVE_SUBSCRIPTION_INFO = 9;
48     byte KEEP_ALIVE_INFO = 10;
49     byte SHUTDOWN_INFO = 11;
50     byte REMOVE_INFO = 12;
51     byte CONTROL_COMMAND = 14;
52     byte FLUSH_COMMAND = 15;
53     byte CONNECTION_ERROR = 16;
54     byte CONSUMER_CONTROL = 17;
55     byte CONNECTION_CONTROL = 18;
56     
57     ///////////////////////////////////////////////////
58 //
59 // Messages that go back and forth between the client
60 // and the server.
61 //
62 ///////////////////////////////////////////////////
63 byte PRODUCER_ACK = 19;
64     byte MESSAGE_PULL = 20;
65     byte MESSAGE_DISPATCH = 21;
66     byte MESSAGE_ACK = 22;
67     
68     byte ACTIVEMQ_MESSAGE = 23;
69     byte ACTIVEMQ_BYTES_MESSAGE = 24;
70     byte ACTIVEMQ_MAP_MESSAGE = 25;
71     byte ACTIVEMQ_OBJECT_MESSAGE = 26;
72     byte ACTIVEMQ_STREAM_MESSAGE = 27;
73     byte ACTIVEMQ_TEXT_MESSAGE = 28;
74     byte ACTIVEMQ_BLOB_MESSAGE = 29;
75
76     ///////////////////////////////////////////////////
77 //
78 // Command Response messages
79 //
80 ///////////////////////////////////////////////////
81 byte RESPONSE = 30;
82     byte EXCEPTION_RESPONSE = 31;
83     byte DATA_RESPONSE = 32;
84     byte DATA_ARRAY_RESPONSE = 33;
85     byte INTEGER_RESPONSE = 34;
86
87
88     ///////////////////////////////////////////////////
89 //
90 // Used by discovery
91 //
92 ///////////////////////////////////////////////////
93 byte DISCOVERY_EVENT = 40;
94     
95     ///////////////////////////////////////////////////
96 //
97 // Command object used by the Journal
98 //
99 ///////////////////////////////////////////////////
100 byte JOURNAL_ACK = 50;
101     byte JOURNAL_REMOVE = 52;
102     byte JOURNAL_TRACE = 53;
103     byte JOURNAL_TRANSACTION = 54;
104     byte DURABLE_SUBSCRIPTION_INFO = 55;
105
106
107     ///////////////////////////////////////////////////
108 //
109 // Reliability and fragmentation
110 //
111 ///////////////////////////////////////////////////
112 byte PARTIAL_COMMAND = 60;
113     byte PARTIAL_LAST_COMMAND = 61;
114     
115     byte REPLAY = 65;
116
117
118
119     
120     ///////////////////////////////////////////////////
121 //
122 // Types used represent basic Java types.
123 //
124 ///////////////////////////////////////////////////
125 byte BYTE_TYPE = 70;
126     byte CHAR_TYPE = 71;
127     byte SHORT_TYPE = 72;
128     byte INTEGER_TYPE = 73;
129     byte LONG_TYPE = 74;
130     byte DOUBLE_TYPE = 75;
131     byte FLOAT_TYPE = 76;
132     byte STRING_TYPE = 77;
133     byte BOOLEAN_TYPE = 78;
134     byte BYTE_ARRAY_TYPE = 79;
135     
136    
137     
138    
139     
140     
141     ///////////////////////////////////////////////////
142 //
143 // Broker to Broker command objects
144 //
145 ///////////////////////////////////////////////////
146
147     byte MESSAGE_DISPATCH_NOTIFICATION = 90;
148     byte NETWORK_BRIDGE_FILTER = 91;
149     
150     
151     ///////////////////////////////////////////////////
152 //
153 // Data structures contained in the command objects.
154 //
155 ///////////////////////////////////////////////////
156 byte ACTIVEMQ_QUEUE = 100;
157     byte ACTIVEMQ_TOPIC = 101;
158     byte ACTIVEMQ_TEMP_QUEUE = 102;
159     byte ACTIVEMQ_TEMP_TOPIC = 103;
160     
161     byte MESSAGE_ID = 110;
162     byte ACTIVEMQ_LOCAL_TRANSACTION_ID = 111;
163     byte ACTIVEMQ_XA_TRANSACTION_ID = 112;
164
165     byte CONNECTION_ID = 120;
166     byte SESSION_ID = 121;
167     byte CONSUMER_ID = 122;
168     byte PRODUCER_ID = 123;
169     byte BROKER_ID = 124;
170     
171     
172     
173    
174    
175
176
177 }
178
Popular Tags