|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Packet
Denotes an object that can be serialized/deserailized using a PacketReader or PacketWriter
Field Summary | |
---|---|
static int |
ACTIVEMQ_BROKER_INFO
Broker infomation message |
static int |
ACTIVEMQ_BYTES_MESSAGE
ActiveMQBytesMessage |
static int |
ACTIVEMQ_CONNECTION_INFO
Connection info message |
static int |
ACTIVEMQ_MAP_MESSAGE
ActiveMQMapMessage object |
static int |
ACTIVEMQ_MESSAGE
ActiveMQMessage object |
static int |
ACTIVEMQ_MSG_ACK
Message acknowledge |
static int |
ACTIVEMQ_OBJECT_MESSAGE
ActiveMQObjectMessage object |
static int |
ACTIVEMQ_STREAM_MESSAGE
ActiveMQStreamMessage object |
static int |
ACTIVEMQ_TEXT_MESSAGE
ActiveMQTextMessage object |
static int |
BROKER_ADMIN_COMMAND
A command to the Broker Admin |
static int |
CACHED_VALUE_COMMAND
transmit cached values for the wire format |
static int |
CAPACITY_INFO
Infomation about the Capacity for more Messages for either Connection/Broker |
static int |
CAPACITY_INFO_REQUEST
Request infomation about the current capacity |
static int |
CLEANUP_CONNECTION_INFO
transmit cached values for the wire format |
static int |
CONSUMER_INFO
Consumer Infomation |
static int |
DURABLE_UNSUBSCRIBE
Durable Unsubscribe message |
static int |
INT_RESPONSE_RECEIPT_INFO
A receipt with an Integer reponse. |
static int |
KEEP_ALIVE
Keep-alive message |
static int |
NOT_SET
Unspecified Packet type |
static int |
PRODUCER_INFO
Producer Info |
static int |
RECEIPT_INFO
Recipt message |
static int |
RESPONSE_RECEIPT_INFO
A receipt with an Object reponse. |
static int |
SESSION_INFO
Session Info message |
static int |
TRANSACTION_INFO
Transaction info |
static int |
WIRE_FORMAT_INFO
Infomation about the wire format expected |
static int |
XA_TRANSACTION_INFO
XA Transaction info |
Method Summary | |
---|---|
void |
addBrokerVisited(String brokerName)
As the packet passes through the broker add the broker to the visited list |
void |
clearBrokersVisited()
clear list of brokers visited |
int |
decrementMemoryReferenceCount()
Decrement reference count for bounded memory collections |
String |
getBrokersVisitedAsString()
|
short |
getId()
|
int |
getMemoryUsage()
Get a hint about how much memory this Packet is consuming |
int |
getMemoryUsageReferenceCount()
|
int |
getPacketType()
Return the type of Packet |
boolean |
hasVisited(String brokerName)
test to see if the named broker has already seen this packet |
int |
incrementMemoryReferenceCount()
Increment reference count for bounded memory collections |
boolean |
isJMSMessage()
Retrieve if a JMS Message type or not |
boolean |
isReceipt()
|
boolean |
isReceiptRequired()
|
void |
setId(short newId)
Set the unique id for this Packet |
void |
setMemoryUsage(int newMemoryUsage)
Set a hint about how mujch memory this packet is consuming |
void |
setReceiptRequired(boolean value)
Set if a Recipt if required on receiving this Packet |
Field Detail |
---|
static final int NOT_SET
static final int ACTIVEMQ_MESSAGE
static final int ACTIVEMQ_TEXT_MESSAGE
static final int ACTIVEMQ_OBJECT_MESSAGE
static final int ACTIVEMQ_BYTES_MESSAGE
static final int ACTIVEMQ_STREAM_MESSAGE
static final int ACTIVEMQ_MAP_MESSAGE
static final int ACTIVEMQ_MSG_ACK
static final int RECEIPT_INFO
static final int CONSUMER_INFO
static final int PRODUCER_INFO
static final int TRANSACTION_INFO
static final int XA_TRANSACTION_INFO
static final int ACTIVEMQ_BROKER_INFO
static final int ACTIVEMQ_CONNECTION_INFO
static final int SESSION_INFO
static final int DURABLE_UNSUBSCRIBE
static final int RESPONSE_RECEIPT_INFO
static final int INT_RESPONSE_RECEIPT_INFO
static final int CAPACITY_INFO
static final int CAPACITY_INFO_REQUEST
static final int WIRE_FORMAT_INFO
static final int KEEP_ALIVE
static final int BROKER_ADMIN_COMMAND
static final int CACHED_VALUE_COMMAND
static final int CLEANUP_CONNECTION_INFO
Method Detail |
---|
int getPacketType()
short getId()
void setId(short newId)
newId
- boolean isReceiptRequired()
boolean isReceipt()
void setReceiptRequired(boolean value)
value
- boolean isJMSMessage()
int getMemoryUsage()
void setMemoryUsage(int newMemoryUsage)
newMemoryUsage
- int incrementMemoryReferenceCount()
MemoryBoundedQueue
int decrementMemoryReferenceCount()
MemoryBoundedQueue
int getMemoryUsageReferenceCount()
MemoryBoundedQueue
void addBrokerVisited(String brokerName)
brokerName
- the name of the brokervoid clearBrokersVisited()
boolean hasVisited(String brokerName)
brokerName
- the name of the broker
String getBrokersVisitedAsString()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |