A B C D E F G H I J L M N O P Q R S T U V W

A

ABORT - Static variable in interface org.fusesource.stompjms.channel.Stomp.Commands
 
ABORT_TRANSACTION - Static variable in interface org.fusesource.stompjms.channel.Stomp.Commands
 
ACK - Static variable in interface org.fusesource.stompjms.channel.Stomp.Commands
 
ACK_MODE - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Subscribe
 
ackMessage(StompJmsDestination, String, String) - Method in class org.fusesource.stompjms.channel.StompChannel
 
acknowledge() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
acknowledgeCallback - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
add(StompJmsMessageConsumer, boolean) - Method in class org.fusesource.stompjms.StompJmsSession
 
add(MessageProducer) - Method in class org.fusesource.stompjms.StompJmsSession
 
addPropertiesToURI(String, Map<String, String>) - Static method in class org.fusesource.stompjms.util.PropertyUtil
Add properties to a URI
addPropertiesToURIFromBean(String, Object) - Static method in class org.fusesource.stompjms.util.PropertyUtil
Add bean properties to a URI
addSession(StompJmsSession, StompChannel) - Method in class org.fusesource.stompjms.StompJmsConnection
 
AMQ_MESSAGE_TYPE - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers
This header is used to instruct ActiveMQ to construct the message based with a specific type.
AUTO - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Subscribe.AckModeValues
 
available() - Method in class org.fusesource.stompjms.channel.TcpBufferedInputStream
 

B

BEGIN - Static variable in interface org.fusesource.stompjms.channel.Stomp.Commands
 
BEGIN_TRANSACTION - Static variable in interface org.fusesource.stompjms.channel.Stomp.Commands
 
BIG_STRING_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
BOOLEAN_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
BROWSER - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Subscribe
 
buildFromProperties(Map<String, String>) - Method in class org.fusesource.stompjms.jndi.JNDIStorable
Set the properties that will represent the instance in JNDI
buildFromProperties(Map<String, String>) - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
buildFromProperties(Map<String, String>) - Method in class org.fusesource.stompjms.StompJmsDestination
 
BYTE_ARRAY_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
BYTE_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
bytesOut - Variable in class org.fusesource.stompjms.message.StompJmsBytesMessage
 

C

Callback<T> - Interface in org.fusesource.stompjms.util
A simple callback object
CHAR_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
checkClosed() - Method in class org.fusesource.stompjms.StompJmsConnection
 
checkClosed() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
checkClosed() - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
checkClosed() - Method in class org.fusesource.stompjms.StompJmsSession
 
checkReadOnlyBody() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
checkValidObject(Object) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
checkWriteOnlyBody() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
 
checkWriteOnlyBody() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
 
ClassLoadingAwareObjectInputStream - Class in org.fusesource.stompjms.util
 
ClassLoadingAwareObjectInputStream(InputStream) - Constructor for class org.fusesource.stompjms.util.ClassLoadingAwareObjectInputStream
 
clear() - Method in class org.fusesource.stompjms.MessageQueue
 
clearBody() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Clears out the message body.
clearBody() - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Clears out the message body.
clearBody() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
clearBody() - Method in class org.fusesource.stompjms.message.StompJmsObjectMessage
Clears out the message body.
clearBody() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Clears out the message body.
clearBody() - Method in class org.fusesource.stompjms.message.StompJmsTextMessage
Clears out the message body.
clearContent() - Method in class org.fusesource.stompjms.channel.StompFrame
 
clearProperties() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
CLIENT - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Subscribe.AckModeValues
 
CLIENT_ID - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Connect
 
close() - Method in class org.fusesource.stompjms.channel.StompSocket
 
close() - Method in class org.fusesource.stompjms.channel.TcpBufferedInputStream
 
close() - Method in class org.fusesource.stompjms.channel.TcpBufferedOutputStream
close this stream
close() - Method in class org.fusesource.stompjms.MessageQueue
 
close() - Method in class org.fusesource.stompjms.StompJmsConnection
 
close() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
close() - Method in class org.fusesource.stompjms.StompJmsMessageProducer
Close the producer
close() - Method in class org.fusesource.stompjms.StompJmsQueueBrowser
 
close() - Method in class org.fusesource.stompjms.StompJmsSession
 
closed - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
COMMIT - Static variable in interface org.fusesource.stompjms.channel.Stomp.Commands
 
commit() - Method in class org.fusesource.stompjms.StompJmsSession
 
COMMIT_TRANSACTION - Static variable in interface org.fusesource.stompjms.channel.Stomp.Commands
 
commitTransaction() - Method in class org.fusesource.stompjms.channel.StompChannel
 
compareTo(StompJmsDestination) - Method in class org.fusesource.stompjms.StompJmsDestination
 
compress(Buffer) - Static method in class org.fusesource.stompjms.util.IOUtils
Compress the buffer
CONNECT - Static variable in interface org.fusesource.stompjms.channel.Stomp.Commands
 
connect() - Method in class org.fusesource.stompjms.channel.StompChannel
 
connect(String, String, String) - Method in class org.fusesource.stompjms.channel.StompSocket
Configures the socket for use
CONNECTED - Static variable in interface org.fusesource.stompjms.channel.Stomp.Responses
 
consumerId - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
CONTENT_LENGTH - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers
 
CONTENT_TYPE - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers
 
convert(StompJmsMessage) - Static method in class org.fusesource.stompjms.channel.StompTranslator
 
convert(StompFrame) - Static method in class org.fusesource.stompjms.channel.StompTranslator
 
convert(Object, Class) - Static method in class org.fusesource.stompjms.channel.TypeConversionSupport
 
copy() - Method in class org.fusesource.stompjms.channel.StompChannel
 
copy() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
 
copy() - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
 
copy(StompJmsMapMessage) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
 
copy() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
copy(StompJmsMessage) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
copy() - Method in class org.fusesource.stompjms.message.StompJmsObjectMessage
 
copy() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
 
copy(StompJmsStreamMessage) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
 
copy() - Method in class org.fusesource.stompjms.message.StompJmsTextMessage
 
copyJmsHeaders(StompFrame, StompJmsMessage) - Static method in class org.fusesource.stompjms.channel.StompTranslator
 
copyJmsHeaders(StompJmsMessage, StompFrame) - Static method in class org.fusesource.stompjms.channel.StompTranslator
 
copyProperties(Message, Message) - Static method in class org.fusesource.stompjms.message.StompJmsMessageTransformation
Copies the standard JMS and user defined properties from the givem message to the specified message
CORRELATION_ID - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Message
 
CORRELATION_ID - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Send
 
correlationId - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
count - Variable in class org.fusesource.stompjms.channel.TcpBufferedInputStream
 
create(String, Throwable) - Static method in class org.fusesource.stompjms.StompJmsExceptionSupport
 
create(String, Exception) - Static method in class org.fusesource.stompjms.StompJmsExceptionSupport
 
create(Throwable) - Static method in class org.fusesource.stompjms.StompJmsExceptionSupport
 
create(Exception) - Static method in class org.fusesource.stompjms.StompJmsExceptionSupport
 
createBrowser(Queue) - Method in class org.fusesource.stompjms.StompJmsSession
 
createBrowser(Queue, String) - Method in class org.fusesource.stompjms.StompJmsSession
 
createBrowser(Queue) - Method in class org.fusesource.stompjms.StompJmsTopicSession
 
createBrowser(Queue, String) - Method in class org.fusesource.stompjms.StompJmsTopicSession
 
createBytesMessage() - Method in class org.fusesource.stompjms.StompJmsSession
 
createConnection() - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
createConnection(String, String) - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
createConnectionConsumer(Destination, String, ServerSessionPool, int) - Method in class org.fusesource.stompjms.StompJmsConnection
 
createConnectionConsumer(Topic, String, ServerSessionPool, int) - Method in class org.fusesource.stompjms.StompJmsConnection
 
createConnectionConsumer(Queue, String, ServerSessionPool, int) - Method in class org.fusesource.stompjms.StompJmsConnection
 
createConsumer(Destination) - Method in class org.fusesource.stompjms.StompJmsQueueSession
 
createConsumer(Destination, String) - Method in class org.fusesource.stompjms.StompJmsQueueSession
 
createConsumer(Destination, String, boolean) - Method in class org.fusesource.stompjms.StompJmsQueueSession
 
createConsumer(Destination) - Method in class org.fusesource.stompjms.StompJmsSession
 
createConsumer(Destination, String) - Method in class org.fusesource.stompjms.StompJmsSession
 
createConsumer(Destination, String, boolean) - Method in class org.fusesource.stompjms.StompJmsSession
 
createConsumer(Destination) - Method in class org.fusesource.stompjms.StompJmsTopicSession
 
createConsumer(Destination, String) - Method in class org.fusesource.stompjms.StompJmsTopicSession
 
createDestination(String) - Static method in class org.fusesource.stompjms.StompJmsDestination
 
createDurableConnectionConsumer(Topic, String, String, ServerSessionPool, int) - Method in class org.fusesource.stompjms.StompJmsConnection
 
createDurableSubscriber(Topic, String) - Method in class org.fusesource.stompjms.StompJmsQueueSession
 
createDurableSubscriber(Topic, String, String, boolean) - Method in class org.fusesource.stompjms.StompJmsQueueSession
 
createDurableSubscriber(Topic, String) - Method in class org.fusesource.stompjms.StompJmsSession
 
createDurableSubscriber(Topic, String, String, boolean) - Method in class org.fusesource.stompjms.StompJmsSession
 
createMapMessage() - Method in class org.fusesource.stompjms.StompJmsSession
 
createMessage() - Method in class org.fusesource.stompjms.StompJmsSession
 
createMessageEOFException(Exception) - Static method in class org.fusesource.stompjms.StompJmsExceptionSupport
 
createMessageFormatException(Throwable) - Static method in class org.fusesource.stompjms.StompJmsExceptionSupport
 
createObjectMessage() - Method in class org.fusesource.stompjms.StompJmsSession
 
createObjectMessage(Serializable) - Method in class org.fusesource.stompjms.StompJmsSession
 
createProducer(Destination) - Method in class org.fusesource.stompjms.StompJmsQueueSession
 
createProducer(Destination) - Method in class org.fusesource.stompjms.StompJmsSession
 
createProducer(Destination) - Method in class org.fusesource.stompjms.StompJmsTopicSession
 
createPublisher(Topic) - Method in class org.fusesource.stompjms.StompJmsQueueSession
 
createPublisher(Topic) - Method in class org.fusesource.stompjms.StompJmsSession
 
createQueue(String) - Method in class org.fusesource.stompjms.StompJmsSession
 
createQueue(String) - Method in class org.fusesource.stompjms.StompJmsTopicSession
 
createQueueConnection() - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
createQueueConnection(String, String) - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
createQueueSession(boolean, int) - Method in class org.fusesource.stompjms.StompJmsConnection
 
createReceiver(Queue) - Method in class org.fusesource.stompjms.StompJmsSession
 
createReceiver(Queue, String) - Method in class org.fusesource.stompjms.StompJmsSession
 
createReceiver(Queue) - Method in class org.fusesource.stompjms.StompJmsTopicSession
 
createReceiver(Queue, String) - Method in class org.fusesource.stompjms.StompJmsTopicSession
 
createReference(String, JNDIStorable) - Static method in class org.fusesource.stompjms.jndi.JNDIReferenceFactory
Create a Reference instance from a JNDIStorable object
createSender(Queue) - Method in class org.fusesource.stompjms.StompJmsSession
 
createSender(Queue) - Method in class org.fusesource.stompjms.StompJmsTopicSession
 
createSession(boolean, int) - Method in class org.fusesource.stompjms.StompJmsConnection
 
createStreamMessage() - Method in class org.fusesource.stompjms.StompJmsSession
 
createSubscriber(Topic) - Method in class org.fusesource.stompjms.StompJmsQueueSession
 
createSubscriber(Topic, String, boolean) - Method in class org.fusesource.stompjms.StompJmsQueueSession
 
createSubscriber(Topic) - Method in class org.fusesource.stompjms.StompJmsSession
 
createSubscriber(Topic, String, boolean) - Method in class org.fusesource.stompjms.StompJmsSession
 
createTemporaryQueue() - Method in class org.fusesource.stompjms.StompJmsSession
 
createTemporaryQueue() - Method in class org.fusesource.stompjms.StompJmsTopicSession
 
createTemporaryTopic() - Method in class org.fusesource.stompjms.StompJmsQueueSession
 
createTemporaryTopic() - Method in class org.fusesource.stompjms.StompJmsSession
 
createTextMessage() - Method in class org.fusesource.stompjms.StompJmsSession
 
createTextMessage(String) - Method in class org.fusesource.stompjms.StompJmsSession
 
createTopic(String) - Method in class org.fusesource.stompjms.StompJmsQueueSession
 
createTopic(String) - Method in class org.fusesource.stompjms.StompJmsSession
 
createTopicConnection() - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
createTopicConnection(String, String) - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
createTopicSession(boolean, int) - Method in class org.fusesource.stompjms.StompJmsConnection
 

D

dataIn - Variable in class org.fusesource.stompjms.message.StompJmsBytesMessage
 
dataIn - Variable in class org.fusesource.stompjms.message.StompJmsStreamMessage
 
dataOut - Variable in class org.fusesource.stompjms.message.StompJmsStreamMessage
 
decodeString(byte[]) - Static method in class org.fusesource.stompjms.message.StompJmsMessage
 
delete() - Method in class org.fusesource.stompjms.StompJmsTempQueue
 
delete() - Method in class org.fusesource.stompjms.StompJmsTempTopic
 
deliveryMode - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
dequeue(long) - Method in class org.fusesource.stompjms.MessageQueue
 
dequeueNoWait() - Method in class org.fusesource.stompjms.MessageQueue
 
DESTINATION - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Message
 
DESTINATION - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Send
 
DESTINATION - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Subscribe
 
DESTINATION - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Unsubscribe
 
destination - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
destination - Variable in class org.fusesource.stompjms.StompJmsMessageConsumer
 
destination - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
disableMessageId - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
disableTimestamp - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
DISCONNECT - Static variable in interface org.fusesource.stompjms.channel.Stomp.Commands
 
DOUBLE_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 

E

encodeString(String) - Static method in class org.fusesource.stompjms.message.StompJmsMessage
 
enqueue(StompJmsMessage) - Method in class org.fusesource.stompjms.MessageQueue
 
enqueueFirst(StompJmsMessage) - Method in class org.fusesource.stompjms.MessageQueue
 
equals(Object) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
equals(Object) - Method in class org.fusesource.stompjms.StompJmsDestination
 
equals(Object) - Method in class org.fusesource.stompjms.util.PropertyExpression
 
ERROR - Static variable in interface org.fusesource.stompjms.channel.Stomp.Responses
 
evaluate(StompJmsMessage) - Method in class org.fusesource.stompjms.util.PropertyExpression
 
execute(T) - Method in interface org.fusesource.stompjms.util.Callback
Executes some piece of code
expiration - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
EXPIRATION_TIME - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Message
 
EXPIRATION_TIME - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Send
 

F

fill() - Method in class org.fusesource.stompjms.channel.TcpBufferedInputStream
 
flexibleDestination - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
FLOAT_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
flush() - Method in class org.fusesource.stompjms.channel.TcpBufferedOutputStream
flush the data to the output stream This doesn't call flush on the underlying outputstream, because Tcp is particularly efficent at doing this itself ....
frame - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 

G

get(long) - Method in class org.fusesource.stompjms.util.SendRequest
 
getAckMode() - Method in class org.fusesource.stompjms.channel.StompChannel
 
getAcknowledgeCallback() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getAcknowledgeMode() - Method in class org.fusesource.stompjms.StompJmsSession
 
getAction() - Method in class org.fusesource.stompjms.channel.StompFrame
 
getAllPropertyNames() - Method in class org.fusesource.stompjms.message.StompJmsMessage
return all property names, including standard JMS properties and JMSX properties
getBody() - Method in class org.fusesource.stompjms.channel.StompFrame
 
getBodyLength() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Gets the number of bytes of the message body when the message is in read-only mode.
getBoolean(String) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Returns the boolean value with the specified name.
getBooleanProperty(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getBrokerURI() - Method in class org.fusesource.stompjms.channel.StompChannel
 
getBrokerURI() - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
getBuffer(Object) - Static method in class org.fusesource.stompjms.util.IOUtils
Create a Buffer from an Object
getByte(String) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Returns the byte value with the specified name.
getByteBufferInputStream(ByteBuffer) - Static method in class org.fusesource.stompjms.util.IOUtils
Create an InputStream to read a ByteBuffer
getByteBufferOutputStream(ByteBuffer) - Static method in class org.fusesource.stompjms.util.IOUtils
Create an OutputStream for a ByteBuffer
getByteProperty(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getBytes(String) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Returns the byte array value with the specified name.
getChannel() - Method in class org.fusesource.stompjms.StompJmsConnection
 
getChannel() - Method in class org.fusesource.stompjms.StompJmsSession
 
getChannelId() - Method in class org.fusesource.stompjms.channel.StompChannel
 
getChar(String) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Returns the Unicode character value with the specified name.
getClientID() - Method in class org.fusesource.stompjms.StompJmsConnection
 
getConnection() - Method in class org.fusesource.stompjms.StompJmsSession
 
getConnectionTimeout() - Method in class org.fusesource.stompjms.channel.StompSocket
 
getConsumerId() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getContent() - Method in class org.fusesource.stompjms.channel.StompFrame
 
getContent() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getContentMap() - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
 
getDeliveryMode() - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
getDestination(StompFrame) - Static method in class org.fusesource.stompjms.channel.StompTranslator
 
getDestination() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
getDestination() - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
getDisableMessageID() - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
getDisableMessageTimestamp() - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
getDouble(String) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Returns the double value with the specified name.
getDoubleProperty(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getEnumeration() - Method in class org.fusesource.stompjms.StompJmsQueueBrowser
Gets an enumeration for browsing the current queue messages in the order they would be received.
getException() - Method in class org.fusesource.stompjms.channel.StompFrameError
 
getExceptionListener() - Method in class org.fusesource.stompjms.StompJmsConnection
 
getFloat(String) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Returns the float value with the specified name.
getFloatProperty(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getHeaders() - Method in class org.fusesource.stompjms.channel.StompFrame
 
getId() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
getInt(String) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Returns the int value with the specified name.
getIntProperty(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getIoBufferSize() - Method in class org.fusesource.stompjms.channel.StompSocket
 
getJMSCorrelationID() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getJMSCorrelationIDAsBytes() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getJMSDeliveryMode() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getJMSDestination() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getJMSExpiration() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getJmsHeaders(StompFrame) - Static method in class org.fusesource.stompjms.channel.StompTranslator
 
getJMSMajorVersion() - Method in class org.fusesource.stompjms.StompJmsConnectionMetaData
Gets the JMS major version number.
getJMSMessageID() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getJMSMinorVersion() - Method in class org.fusesource.stompjms.StompJmsConnectionMetaData
Gets the JMS minor version number.
getJMSPriority() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getJMSProviderName() - Method in class org.fusesource.stompjms.StompJmsConnectionMetaData
Gets the JMS provider name.
getJMSRedelivered() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getJMSReplyTo() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getJMSTimestamp() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getJMSType() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getJMSVersion() - Method in class org.fusesource.stompjms.StompJmsConnectionMetaData
Gets the JMS API version.
getJMSXMimeType() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
 
getJMSXMimeType() - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
 
getJMSXMimeType() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getJMSXMimeType() - Method in class org.fusesource.stompjms.message.StompJmsObjectMessage
 
getJMSXMimeType() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
 
getJMSXMimeType() - Method in class org.fusesource.stompjms.message.StompJmsTextMessage
 
getJMSXPropertyNames() - Method in class org.fusesource.stompjms.StompJmsConnectionMetaData
Gets an enumeration of the JMSX property names.
getKeepAlive() - Method in class org.fusesource.stompjms.channel.StompSocket
 
getListener() - Method in class org.fusesource.stompjms.channel.StompChannel
 
getLocalURI() - Method in class org.fusesource.stompjms.channel.StompChannel
 
getLocalURI() - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
getLong(String) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Returns the long value with the specified name.
getLongProperty(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getMapNames() - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Returns an Enumeration of all the names in the MapMessage object.
getMaxCacheSize() - Method in class org.fusesource.stompjms.util.LRUCache
 
getMessageListener() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
getMessageListener() - Method in class org.fusesource.stompjms.StompJmsSession
 
getMessageQueueSize() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
getMessageSelector() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
getMessageSelector() - Method in class org.fusesource.stompjms.StompJmsQueueBrowser
 
getMetaData() - Method in class org.fusesource.stompjms.StompJmsConnection
 
getMsgType() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
 
getMsgType() - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
 
getMsgType() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getMsgType() - Method in class org.fusesource.stompjms.message.StompJmsObjectMessage
 
getMsgType() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
 
getMsgType() - Method in class org.fusesource.stompjms.message.StompJmsTextMessage
 
getMutex() - Method in class org.fusesource.stompjms.MessageQueue
 
getName() - Method in class org.fusesource.stompjms.util.PropertyExpression
 
getNoLocal() - Method in class org.fusesource.stompjms.StompJmsTopicSubscriber
 
getObject(String) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Returns the value of the object with the specified name.
getObject() - Method in class org.fusesource.stompjms.message.StompJmsObjectMessage
Gets the serializable object containing this message's data.
getObject(Buffer) - Static method in class org.fusesource.stompjms.util.IOUtils
Create an Object from a Buffer
getObjectInstance(Object, Name, Context, Hashtable<?, ?>) - Method in class org.fusesource.stompjms.jndi.JNDIReferenceFactory
This will be called by a JNDIprovider when a Reference is retrieved from a JNDI store - and generates the orignal instance
getObjectProperty(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getPassword() - Method in class org.fusesource.stompjms.channel.StompChannel
 
getPassword() - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
getPhysicalName() - Method in class org.fusesource.stompjms.StompJmsDestination
 
getPriority() - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
getProperties() - Method in class org.fusesource.stompjms.jndi.JNDIStorable
Get the properties from this instance for storing in JNDI
getProperties() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getProperties(Object) - Static method in class org.fusesource.stompjms.util.PropertyUtil
Get properties from an object
getProperty(Map<String, String>, String, String) - Method in class org.fusesource.stompjms.jndi.JNDIStorable
 
getPropertyNames() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getProviderMajorVersion() - Method in class org.fusesource.stompjms.StompJmsConnectionMetaData
Gets the JMS provider major version number.
getProviderMinorVersion() - Method in class org.fusesource.stompjms.StompJmsConnectionMetaData
Gets the JMS provider minor version number.
getProviderVersion() - Method in class org.fusesource.stompjms.StompJmsConnectionMetaData
Gets the JMS provider version.
getQueue() - Method in class org.fusesource.stompjms.StompJmsQueueBrowser
Gets the queue associated with this queue browser.
getQueue() - Method in class org.fusesource.stompjms.StompJmsQueueReceiver
 
getQueue() - Method in class org.fusesource.stompjms.StompJmsQueueSender
 
getQueueName() - Method in class org.fusesource.stompjms.StompJmsQueue
 
getQueueName() - Method in class org.fusesource.stompjms.StompJmsTempQueue
 
getRedeliveryCounter() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getReference() - Method in class org.fusesource.stompjms.jndi.JNDIStorable
Retrive a Reference for this instance to store in JNDI
getRemoteAddress() - Method in class org.fusesource.stompjms.channel.StompSocket
 
getReplyTo(StompFrame) - Static method in class org.fusesource.stompjms.channel.StompTranslator
 
getSessionAcknowledgeMode(boolean, int) - Method in class org.fusesource.stompjms.StompJmsConnection
 
getShort(String) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Returns the short value with the specified name.
getShortProperty(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getSocketBufferSize() - Method in class org.fusesource.stompjms.channel.StompSocket
 
getSoTimeout() - Method in class org.fusesource.stompjms.channel.StompSocket
 
getStompJmsDestination() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getStompJmsReplyTo() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getString(String) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Returns the String value with the specified name.
getStringProperty(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getTcpNoDelay() - Method in class org.fusesource.stompjms.channel.StompSocket
 
getText() - Method in class org.fusesource.stompjms.message.StompJmsTextMessage
 
getTimeToLive() - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
getTopic() - Method in class org.fusesource.stompjms.StompJmsTopicPublisher
 
getTopic() - Method in class org.fusesource.stompjms.StompJmsTopicSubscriber
 
getTopicName() - Method in class org.fusesource.stompjms.StompJmsTempTopic
 
getTopicName() - Method in class org.fusesource.stompjms.StompJmsTopic
 
getTransacted() - Method in class org.fusesource.stompjms.StompJmsSession
 
getTransactionId() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getType() - Method in class org.fusesource.stompjms.StompJmsDestination
 
getType() - Method in class org.fusesource.stompjms.StompJmsQueue
 
getType() - Method in class org.fusesource.stompjms.StompJmsTempQueue
 
getType() - Method in class org.fusesource.stompjms.StompJmsTempTopic
 
getType() - Method in class org.fusesource.stompjms.StompJmsTopic
 
getUserName() - Method in class org.fusesource.stompjms.channel.StompChannel
 
getUsername() - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
getValue(String) - Static method in enum org.fusesource.stompjms.channel.Stomp.Transformations
 

H

hashCode() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
hashCode() - Method in class org.fusesource.stompjms.StompJmsDestination
 
hashCode() - Method in class org.fusesource.stompjms.util.PropertyExpression
 
hashValue - Variable in class org.fusesource.stompjms.StompJmsDestination
 
hasMoreElements() - Method in class org.fusesource.stompjms.StompJmsQueueBrowser
 

I

ID - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Subscribe
 
ID - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Unsubscribe
 
incrementRedeliveryCounter() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
INDIVIDUAL - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Subscribe.AckModeValues
 
inflate(Buffer) - Static method in class org.fusesource.stompjms.util.IOUtils
Inflate a compressed buffer
initialize() - Method in class org.fusesource.stompjms.channel.StompChannel
 
initialize() - Method in class org.fusesource.stompjms.channel.StompSocket
 
INSTANCE - Static variable in class org.fusesource.stompjms.StompJmsConnectionMetaData
 
INTEGER_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
internalBuffer - Variable in class org.fusesource.stompjms.channel.TcpBufferedInputStream
 
IOUtils - Class in org.fusesource.stompjms.util
Utilities for ByteBuffers
IOUtils() - Constructor for class org.fusesource.stompjms.util.IOUtils
 
isClosed() - Method in class org.fusesource.stompjms.MessageQueue
 
isConnected() - Method in class org.fusesource.stompjms.channel.StompSocket
 
isEmpty() - Method in class org.fusesource.stompjms.MessageQueue
 
isFatal() - Method in exception org.fusesource.stompjms.channel.ProtocolException
 
isPersistent() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
isQueue() - Method in class org.fusesource.stompjms.StompJmsDestination
 
isRedelivered() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
isRunning() - Method in class org.fusesource.stompjms.MessageQueue
 
isStarted() - Method in class org.fusesource.stompjms.channel.StompChannel
 
isStarted() - Method in class org.fusesource.stompjms.channel.StompSocket
 
isStarted() - Method in class org.fusesource.stompjms.StompJmsSession
 
isStopped() - Method in class org.fusesource.stompjms.channel.StompSocket
 
isStopping() - Method in class org.fusesource.stompjms.channel.StompSocket
 
isTemporary() - Method in class org.fusesource.stompjms.StompJmsDestination
 
isTopic() - Method in class org.fusesource.stompjms.StompJmsDestination
 
itemExists(String) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Indicates whether an item exists in this MapMessage object.

J

JNDIReferenceFactory - Class in org.fusesource.stompjms.jndi
Converts objects implementing JNDIStorable into a property fields so they can be stored and regenerated from JNDI
JNDIReferenceFactory() - Constructor for class org.fusesource.stompjms.jndi.JNDIReferenceFactory
 
JNDIStorable - Class in org.fusesource.stompjms.jndi
Facilitates objects to be stored in JNDI as properties
JNDIStorable() - Constructor for class org.fusesource.stompjms.jndi.JNDIStorable
 

L

lazyCreateProperties() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
length - Variable in class org.fusesource.stompjms.message.StompJmsBytesMessage
 
LIST_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
loadClass(Object, String) - Static method in class org.fusesource.stompjms.jndi.JNDIReferenceFactory
Retrieve the class loader for a named class
LOGIN - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Connect
 
LONG_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
LRUCache<K,V> - Class in org.fusesource.stompjms.util
A Simple LRU Cache
LRUCache() - Constructor for class org.fusesource.stompjms.util.LRUCache
Default constructor for an LRU Cache The default capacity is 10000
LRUCache(int) - Constructor for class org.fusesource.stompjms.util.LRUCache
Constructs a LRUCache with a maximum capacity
LRUCache(int, int, float, boolean) - Constructor for class org.fusesource.stompjms.util.LRUCache
Constructs an empty LRUCache instance with the specified initial capacity, maximumCacheSize,load factor and ordering mode.

M

map - Variable in class org.fusesource.stompjms.message.StompJmsMapMessage
 
MAP_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
markSupported() - Method in class org.fusesource.stompjms.channel.TcpBufferedInputStream
 
marshalBoolean(DataByteArrayOutputStream, boolean) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
marshalByte(DataByteArrayOutputStream, byte) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
marshalByteArray(DataByteArrayOutputStream, byte[]) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
marshalByteArray(DataByteArrayOutputStream, byte[], int, int) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
marshalChar(DataByteArrayOutputStream, char) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
marshalDouble(DataByteArrayOutputStream, double) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
marshalFloat(DataByteArrayOutputStream, float) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
marshalInt(DataByteArrayOutputStream, int) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
MarshallingSupport - Class in org.fusesource.stompjms.util
The fixed version of the UTF8 encoding function.
marshalLong(DataByteArrayOutputStream, long) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
marshalNull(DataByteArrayOutputStream) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
marshalPrimitive(DataByteArrayOutputStream, Object) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
marshalPrimitiveList(List, DataByteArrayOutputStream) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
marshalPrimitiveMap(Map, DataByteArrayOutputStream) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
marshalShort(DataByteArrayOutputStream, short) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
marshalString(DataByteArrayOutputStream, String) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
maxCacheSize - Variable in class org.fusesource.stompjms.util.LRUCache
 
MESSAGE - Static variable in interface org.fusesource.stompjms.channel.Stomp.Commands
 
MESSAGE - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Error
 
MESSAGE - Static variable in interface org.fusesource.stompjms.channel.Stomp.Responses
 
MESSAGE_ID - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Ack
 
MESSAGE_ID - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Message
 
messageId - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
MessageQueue - Class in org.fusesource.stompjms
 
MessageQueue() - Constructor for class org.fusesource.stompjms.MessageQueue
 

N

NEWLINE - Static variable in interface org.fusesource.stompjms.channel.Stomp
 
nextElement() - Method in class org.fusesource.stompjms.StompJmsQueueBrowser
 
NO_DATA - Static variable in class org.fusesource.stompjms.channel.StompFrame
 
notifyMessageAvailable() - Method in class org.fusesource.stompjms.StompJmsQueueBrowser
 
NULL - Static variable in interface org.fusesource.stompjms.channel.Stomp
 
NULL - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 

O

object - Variable in class org.fusesource.stompjms.message.StompJmsObjectMessage
 
onException(Exception) - Method in class org.fusesource.stompjms.StompJmsConnection
 
onException(JMSException) - Method in class org.fusesource.stompjms.StompJmsConnection
 
onException(Exception) - Method in class org.fusesource.stompjms.StompJmsSession
 
onException(JMSException) - Method in class org.fusesource.stompjms.StompJmsSession
 
onFrame(StompFrame) - Method in class org.fusesource.stompjms.channel.StompChannel
 
onFrame(StompFrame) - Method in interface org.fusesource.stompjms.channel.StompFrameListener
 
onMessage(StompJmsMessage) - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
onMessage(StompJmsMessage) - Method in interface org.fusesource.stompjms.StompJmsMessageListener
Called when a Message is available to be processes
onMessage(StompJmsMessage) - Method in class org.fusesource.stompjms.StompJmsSession
 
onSend() - Method in class org.fusesource.stompjms.message.StompJmsMessage
Send operation event listener.
onSend() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
 
org.fusesource.stompjms - package org.fusesource.stompjms
 
org.fusesource.stompjms.channel - package org.fusesource.stompjms.channel
 
org.fusesource.stompjms.jndi - package org.fusesource.stompjms.jndi
 
org.fusesource.stompjms.message - package org.fusesource.stompjms.message
 
org.fusesource.stompjms.util - package org.fusesource.stompjms.util
 

P

parseContentLength(String) - Method in class org.fusesource.stompjms.channel.StompSocket
 
parseHeaders(DataInput) - Method in class org.fusesource.stompjms.channel.StompSocket
 
parseParameters(URI) - Static method in class org.fusesource.stompjms.util.PropertyUtil
Get properties from a URI
parseParameters(String) - Static method in class org.fusesource.stompjms.util.PropertyUtil
Parse properties from a named resource -eg.
parseQuery(String) - Static method in class org.fusesource.stompjms.util.PropertyUtil
Get properties from a uri
PASSCODE - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Connect
 
peek() - Method in class org.fusesource.stompjms.MessageQueue
 
PERSISTENT - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Send
 
PERSISTENT - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Subscribe
 
persistent - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
physicalName - Variable in class org.fusesource.stompjms.StompJmsDestination
 
populateProperties(Map<String, String>) - Method in class org.fusesource.stompjms.jndi.JNDIStorable
Initialize the instance from properties stored in JNDI
populateProperties(Map<String, String>) - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
populateProperties(Map<String, String>) - Method in class org.fusesource.stompjms.StompJmsDestination
 
position - Variable in class org.fusesource.stompjms.channel.TcpBufferedInputStream
 
PRIORITY - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Message
 
PRIORITY - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Send
 
priority - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
priority - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
PROPERTIES - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Message
 
properties - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
propertyExists(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
PropertyExpression - Class in org.fusesource.stompjms.util
Represents a property expression
PropertyExpression(String) - Constructor for class org.fusesource.stompjms.util.PropertyExpression
 
PropertyUtil - Class in org.fusesource.stompjms.util
Utilities for properties
PropertyUtil() - Constructor for class org.fusesource.stompjms.util.PropertyUtil
 
ProtocolException - Exception in org.fusesource.stompjms.channel
 
ProtocolException() - Constructor for exception org.fusesource.stompjms.channel.ProtocolException
 
ProtocolException(String) - Constructor for exception org.fusesource.stompjms.channel.ProtocolException
 
ProtocolException(String, boolean) - Constructor for exception org.fusesource.stompjms.channel.ProtocolException
 
ProtocolException(String, boolean, Throwable) - Constructor for exception org.fusesource.stompjms.channel.ProtocolException
 
PROVIDER_MAJOR_VERSION - Static variable in class org.fusesource.stompjms.StompJmsConnectionMetaData
 
PROVIDER_MINOR_VERSION - Static variable in class org.fusesource.stompjms.StompJmsConnectionMetaData
 
PROVIDER_VERSION - Static variable in class org.fusesource.stompjms.StompJmsConnectionMetaData
 
publish(Message) - Method in class org.fusesource.stompjms.StompJmsTopicPublisher
 
publish(Topic, Message) - Method in class org.fusesource.stompjms.StompJmsTopicPublisher
 
publish(Message, int, int, long) - Method in class org.fusesource.stompjms.StompJmsTopicPublisher
 
publish(Topic, Message, int, int, long) - Method in class org.fusesource.stompjms.StompJmsTopicPublisher
 
put(String, Object) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
 
put(String, StompFrame) - Method in class org.fusesource.stompjms.util.SendRequest
 

Q

QUEUE_QUALIFIED_PREFIX - Static variable in class org.fusesource.stompjms.StompJmsDestination
 

R

read() - Method in class org.fusesource.stompjms.channel.TcpBufferedInputStream
 
read(byte[], int, int) - Method in class org.fusesource.stompjms.channel.TcpBufferedInputStream
 
readBoolean() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Reads a boolean from the bytes message stream.
readBoolean() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Reads a boolean from the stream message.
readByte() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Reads a signed 8-bit value from the bytes message stream.
readByte() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Reads a byte value from the stream message.
readBytes(byte[]) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Reads a byte array from the bytes message stream.
readBytes(byte[], int) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Reads a portion of the bytes message stream.
readBytes(byte[]) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Reads a byte array field from the stream message into the specified byte[] object (the read buffer).
readChar() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Reads a Unicode character value from the bytes message stream.
readChar() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Reads a Unicode character value from the stream message.
readDouble() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Reads a double from the bytes message stream.
readDouble() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Reads a double from the stream message.
readExternal(ObjectInput) - Method in class org.fusesource.stompjms.jndi.JNDIStorable
 
readExternal(ObjectInput) - Method in class org.fusesource.stompjms.StompJmsDestination
 
readFloat() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Reads a float from the bytes message stream.
readFloat() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Reads a float from the stream message.
readInt() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Reads a signed 32-bit integer from the bytes message stream.
readInt() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Reads a 32-bit integer from the stream message.
readLong() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Reads a signed 64-bit integer from the bytes message stream.
readLong() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Reads a 64-bit integer from the stream message.
readObject() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Reads an object from the stream message.
readObject(DataByteArrayInputStream) - Static method in class org.fusesource.stompjms.util.IOUtils
 
readObjectFromBuffer(Buffer) - Static method in class org.fusesource.stompjms.channel.StompTranslator
 
readObjectFromString(String) - Static method in class org.fusesource.stompjms.channel.StompTranslator
 
readOnlyBody - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
readOnlyProperties - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
readShort() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Reads a signed 16-bit number from the bytes message stream.
readShort() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Reads a 16-bit integer from the stream message.
readString() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Reads a String from the stream message.
readUnsignedByte() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Reads an unsigned 8-bit number from the bytes message stream.
readUnsignedShort() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Reads an unsigned 16-bit number from the bytes message stream.
readUTF() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Reads a string that has been encoded using a modified UTF-8 format from the bytes message stream.
RECEIPT - Static variable in interface org.fusesource.stompjms.channel.Stomp.Responses
 
RECEIPT_ID - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Response
 
RECEIPT_REQUESTED - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers
 
receive() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
receive(long) - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
receiveNoWait() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
recover() - Method in class org.fusesource.stompjms.StompJmsSession
 
REDELIVERED - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Message
 
redeliveryCounter - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
remainingBytes - Variable in class org.fusesource.stompjms.message.StompJmsStreamMessage
 
remove(StompJmsMessageConsumer) - Method in class org.fusesource.stompjms.StompJmsSession
 
remove(MessageProducer) - Method in class org.fusesource.stompjms.StompJmsSession
 
removeAll() - Method in class org.fusesource.stompjms.MessageQueue
 
removeEldestEntry(Map.Entry<K, V>) - Method in class org.fusesource.stompjms.util.LRUCache
 
removeProperty(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
removeSession(StompJmsSession) - Method in class org.fusesource.stompjms.StompJmsConnection
 
REPLY_TO - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Message
 
REPLY_TO - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Send
 
replyTo - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
REQUEST_ID - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Connect
 
reset() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Puts the message body in read-only mode and repositions the stream of bytes to the beginning.
reset() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Puts the message body in read-only mode and repositions the stream of bytes to the beginning.
resolveClass(ObjectStreamClass) - Method in class org.fusesource.stompjms.util.ClassLoadingAwareObjectInputStream
 
resolveProxyClass(String[]) - Method in class org.fusesource.stompjms.util.ClassLoadingAwareObjectInputStream
 
RESPONSE_ID - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Connected
 
rollback(String) - Method in class org.fusesource.stompjms.MessageQueue
 
rollback(String) - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
rollback() - Method in class org.fusesource.stompjms.StompJmsSession
 
rollbackTransaction() - Method in class org.fusesource.stompjms.channel.StompChannel
 
run() - Method in class org.fusesource.stompjms.channel.StompSocket
reads packets from a Socket
run() - Method in class org.fusesource.stompjms.StompJmsSession
 

S

SELECTOR - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Subscribe
 
SEND - Static variable in interface org.fusesource.stompjms.channel.Stomp.Commands
 
send(Message) - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
send(Destination, Message) - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
send(Message, int, int, long) - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
send(Destination, Message, int, int, long) - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
send(Queue, Message) - Method in class org.fusesource.stompjms.StompJmsQueueSender
 
send(Queue, Message, int, int, long) - Method in class org.fusesource.stompjms.StompJmsQueueSender
 
send(Destination, Message, int, int, long) - Method in class org.fusesource.stompjms.StompJmsSession
 
sendFrame(StompFrame) - Method in class org.fusesource.stompjms.channel.StompChannel
 
sendFrame(StompFrame) - Method in class org.fusesource.stompjms.channel.StompSocket
A one way asynchronous send
sendMessage(StompJmsMessage) - Method in class org.fusesource.stompjms.channel.StompChannel
 
sendMessageRequest(StompJmsMessage) - Method in class org.fusesource.stompjms.channel.StompChannel
 
sendRequest(String, StompFrame) - Method in class org.fusesource.stompjms.channel.StompChannel
 
SendRequest - Class in org.fusesource.stompjms.util
state on a request
SendRequest() - Constructor for class org.fusesource.stompjms.util.SendRequest
 
SEPERATOR - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers
 
SESSION - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Connected
 
session - Variable in class org.fusesource.stompjms.StompJmsMessageConsumer
 
session - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
setAckMode(String) - Method in class org.fusesource.stompjms.channel.StompChannel
 
setAcknowledgeCallback(Callback<StompJmsMessage>) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setAction(String) - Method in class org.fusesource.stompjms.channel.StompFrame
 
setBoolean(String, boolean) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Sets a boolean value with the specified name into the Map.
setBooleanProperty(String, boolean) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setBooleanProperty(String, boolean, boolean) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setBrokerURI(URI) - Method in class org.fusesource.stompjms.channel.StompChannel
 
setBrokerURI(String) - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
setByte(String, byte) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Sets a byte value with the specified name into the Map.
setByteProperty(String, byte) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setBytes(String, byte[]) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Sets a byte array value with the specified name into the Map.
setBytes(String, byte[], int, int) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Sets a portion of the byte array value with the specified name into the Map.
setChannelId(String) - Method in class org.fusesource.stompjms.channel.StompChannel
 
setChar(String, char) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Sets a Unicode character value with the specified name into the Map.
setClientID(String) - Method in class org.fusesource.stompjms.StompJmsConnection
 
setConnectionTimeout(int) - Method in class org.fusesource.stompjms.channel.StompSocket
Sets the timeout used to connect to the socket
setConsumerId(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setContent(Buffer) - Method in class org.fusesource.stompjms.channel.StompFrame
 
setContent(Buffer) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setDeliveryMode(int) - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
setDestination(Destination) - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
setDisableMessageID(boolean) - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
setDisableMessageTimestamp(boolean) - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
setDouble(String, double) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Sets a double value with the specified name into the Map.
setDoubleProperty(String, double) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setExceptionListener(ExceptionListener) - Method in class org.fusesource.stompjms.channel.StompChannel
 
setExceptionListener(ExceptionListener) - Method in class org.fusesource.stompjms.channel.StompSocket
 
setExceptionListener(ExceptionListener) - Method in class org.fusesource.stompjms.StompJmsConnection
 
setFloat(String, float) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Sets a float value with the specified name into the Map.
setFloatProperty(String, float) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setHeaders(Map<String, String>) - Method in class org.fusesource.stompjms.channel.StompFrame
 
setInt(String, int) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Sets an int value with the specified name into the Map.
setIntProperty(String, int) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setIoBufferSize(int) - Method in class org.fusesource.stompjms.channel.StompSocket
 
setJMSCorrelationID(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setJMSCorrelationIDAsBytes(byte[]) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setJMSDeliveryMode(int) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setJMSDestination(Destination) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setJMSDestination(StompJmsDestination) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setJMSExpiration(long) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setJMSMessageID(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
Seems to be invalid because the parameter doesn't initialize MessageId instance variables ProducerId and ProducerSequenceId
setJMSPriority(int) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setJMSRedelivered(boolean) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setJMSReplyTo(Destination) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setJMSReplyTo(StompJmsDestination) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setJMSTimestamp(long) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setJMSType(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setKeepAlive(Boolean) - Method in class org.fusesource.stompjms.channel.StompSocket
Enable/disable TCP KEEP_ALIVE mode
setListener(StompJmsMessageListener) - Method in class org.fusesource.stompjms.channel.StompChannel
 
setLocalURI(URI) - Method in class org.fusesource.stompjms.channel.StompChannel
 
setLocalURI(String) - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
setLong(String, long) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Sets a long value with the specified name into the Map.
setLongProperty(String, long) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setMaxCacheSize(int) - Method in class org.fusesource.stompjms.util.LRUCache
 
setMessageListener(MessageListener) - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
setMessageListener(MessageListener) - Method in class org.fusesource.stompjms.StompJmsSession
 
setObject(String, Object) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Sets an object value with the specified name into the Map.
setObject(Serializable) - Method in class org.fusesource.stompjms.message.StompJmsObjectMessage
Sets the serializable object containing this message's data.
setObjectProperty(String, Object) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
 
setObjectProperty(String, Object) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setObjectProperty(String, Object, boolean) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setPassword(String) - Method in class org.fusesource.stompjms.channel.StompChannel
 
setPassword(String) - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
setPersistent(boolean) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setPriority(int) - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
setProperties(Map<String, String>) - Method in class org.fusesource.stompjms.jndi.JNDIStorable
set the properties for this instance as retrieved from JNDI
setProperties(Map<String, Object>) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setProperties(Properties) - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
Set properties
setProperties(Map<String, String>) - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
setProperties(Object, Map<String, String>) - Static method in class org.fusesource.stompjms.util.PropertyUtil
Set properties on an object
setProperty(String, Object) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setProperty(Object, String, Object) - Static method in class org.fusesource.stompjms.util.PropertyUtil
Set a property
setReadOnlyBody(boolean) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setReadOnlyProperties(boolean) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setRedelivered(boolean) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setRedeliveryCounter(int) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setShort(String, short) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Sets a short value with the specified name into the Map.
setShortProperty(String, short) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setSocketBufferSize(int) - Method in class org.fusesource.stompjms.channel.StompSocket
Sets the buffer size to use on the socket
setSoTimeout(int) - Method in class org.fusesource.stompjms.channel.StompSocket
Sets the socket timeout
setStompFrameListener(StompFrameListener) - Method in class org.fusesource.stompjms.channel.StompSocket
 
setString(String, String) - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
Sets a String value with the specified name into the Map.
setStringProperty(String, String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setTcpNoDelay(Boolean) - Method in class org.fusesource.stompjms.channel.StompSocket
Enable/disable the TCP_NODELAY option on the socket
setText(String) - Method in class org.fusesource.stompjms.message.StompJmsTextMessage
 
setTimeToLive(long) - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
setTransactionId(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setUserName(String) - Method in class org.fusesource.stompjms.channel.StompChannel
 
setUsername(String) - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
SHORT_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
size() - Method in class org.fusesource.stompjms.MessageQueue
 
skip(long) - Method in class org.fusesource.stompjms.channel.TcpBufferedInputStream
 
start() - Method in class org.fusesource.stompjms.channel.StompChannel
 
start() - Method in class org.fusesource.stompjms.channel.StompSocket
Start receiving messages
start() - Method in class org.fusesource.stompjms.MessageQueue
 
start() - Method in class org.fusesource.stompjms.StompJmsConnection
 
start() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
start() - Method in class org.fusesource.stompjms.StompJmsSession
 
startTransaction() - Method in class org.fusesource.stompjms.channel.StompChannel
 
Stomp - Interface in org.fusesource.stompjms.channel
 
Stomp.Commands - Interface in org.fusesource.stompjms.channel
 
Stomp.Headers - Interface in org.fusesource.stompjms.channel
 
Stomp.Headers.Ack - Interface in org.fusesource.stompjms.channel
 
Stomp.Headers.Connect - Interface in org.fusesource.stompjms.channel
 
Stomp.Headers.Connected - Interface in org.fusesource.stompjms.channel
 
Stomp.Headers.Error - Interface in org.fusesource.stompjms.channel
 
Stomp.Headers.Message - Interface in org.fusesource.stompjms.channel
 
Stomp.Headers.Response - Interface in org.fusesource.stompjms.channel
 
Stomp.Headers.Send - Interface in org.fusesource.stompjms.channel
 
Stomp.Headers.Subscribe - Interface in org.fusesource.stompjms.channel
 
Stomp.Headers.Subscribe.AckModeValues - Interface in org.fusesource.stompjms.channel
 
Stomp.Headers.Unsubscribe - Interface in org.fusesource.stompjms.channel
 
Stomp.Responses - Interface in org.fusesource.stompjms.channel
 
Stomp.Transformations - Enum in org.fusesource.stompjms.channel
 
StompChannel - Class in org.fusesource.stompjms.channel
 
StompChannel() - Constructor for class org.fusesource.stompjms.channel.StompChannel
 
StompFrame - Class in org.fusesource.stompjms.channel
Represents all the data in a STOMP frame.
StompFrame(String) - Constructor for class org.fusesource.stompjms.channel.StompFrame
 
StompFrame(String, Map<String, String>) - Constructor for class org.fusesource.stompjms.channel.StompFrame
 
StompFrame(String, Map<String, String>, Buffer) - Constructor for class org.fusesource.stompjms.channel.StompFrame
 
StompFrame(String, Map<String, String>, byte[]) - Constructor for class org.fusesource.stompjms.channel.StompFrame
 
StompFrame() - Constructor for class org.fusesource.stompjms.channel.StompFrame
 
StompFrameError - Class in org.fusesource.stompjms.channel
Command indicating that an invalid Stomp Frame was received.
StompFrameError(ProtocolException) - Constructor for class org.fusesource.stompjms.channel.StompFrameError
 
StompFrameListener - Interface in org.fusesource.stompjms.channel
 
StompJmsBytesMessage - Class in org.fusesource.stompjms.message
A BytesMessage object is used to send a message containing a stream of uninterpreted bytes.
StompJmsBytesMessage() - Constructor for class org.fusesource.stompjms.message.StompJmsBytesMessage
 
StompJmsConnection - Class in org.fusesource.stompjms
Implementation of a JMS Connection
StompJmsConnection(URI, URI, String, String) - Constructor for class org.fusesource.stompjms.StompJmsConnection
 
StompJmsConnectionClosedException - Exception in org.fusesource.stompjms
An exception thrown when attempt is made to use a connection when the connection has been closed.
StompJmsConnectionClosedException() - Constructor for exception org.fusesource.stompjms.StompJmsConnectionClosedException
 
StompJmsConnectionFactory - Class in org.fusesource.stompjms
Jms ConnectionFactory implementation
StompJmsConnectionFactory() - Constructor for class org.fusesource.stompjms.StompJmsConnectionFactory
Constructor
StompJmsConnectionMetaData - Class in org.fusesource.stompjms
A ConnectionMetaData object provides information describing the Connection object.
StompJmsDestination - Class in org.fusesource.stompjms
Jms Destination
StompJmsDestination(String) - Constructor for class org.fusesource.stompjms.StompJmsDestination
 
StompJmsExceptionSupport - Class in org.fusesource.stompjms
Create those nice, old fashioned JMS Exceptions
StompJmsMapMessage - Class in org.fusesource.stompjms.message
A MapMessage object is used to send a set of name-value pairs.
StompJmsMapMessage() - Constructor for class org.fusesource.stompjms.message.StompJmsMapMessage
 
StompJmsMessage - Class in org.fusesource.stompjms.message
 
StompJmsMessage() - Constructor for class org.fusesource.stompjms.message.StompJmsMessage
 
StompJmsMessage.JmsMsgType - Enum in org.fusesource.stompjms.message
 
StompJmsMessageConsumer - Class in org.fusesource.stompjms
implementation of a Jms Message Consumer
StompJmsMessageConsumer(String, StompJmsSession, StompJmsDestination, String) - Constructor for class org.fusesource.stompjms.StompJmsMessageConsumer
 
StompJmsMessageListener - Interface in org.fusesource.stompjms
A listener for BlazeMessages
StompJmsMessageProducer - Class in org.fusesource.stompjms
Implementation of a Jms MessageProducer
StompJmsMessageProducer(StompJmsSession, StompJmsDestination) - Constructor for class org.fusesource.stompjms.StompJmsMessageProducer
 
StompJmsMessageTransformation - Class in org.fusesource.stompjms.message
A helper class for converting normal JMS interfaces into StompJms specific ones.
StompJmsObjectMessage - Class in org.fusesource.stompjms.message
An ObjectMessage object is used to send a message that contains a serializable object in the Java programming language ("Java object").
StompJmsObjectMessage() - Constructor for class org.fusesource.stompjms.message.StompJmsObjectMessage
 
StompJmsQueue - Class in org.fusesource.stompjms
Queue implementation
StompJmsQueue(String) - Constructor for class org.fusesource.stompjms.StompJmsQueue
Constructor
StompJmsQueueBrowser - Class in org.fusesource.stompjms
A client uses a QueueBrowser object to look at messages on a queue without removing them.
StompJmsQueueBrowser(StompJmsSession, String, StompJmsDestination, String) - Constructor for class org.fusesource.stompjms.StompJmsQueueBrowser
Constructor for an StompJmsQueueBrowser - used internally
StompJmsQueueReceiver - Class in org.fusesource.stompjms
Implementation of a Jms QueueReceiver
StompJmsQueueReceiver(String, StompJmsSession, StompJmsDestination, String) - Constructor for class org.fusesource.stompjms.StompJmsQueueReceiver
Constructor
StompJmsQueueSender - Class in org.fusesource.stompjms
Implementation of a Queue Sender
StompJmsQueueSender(StompJmsSession, StompJmsDestination) - Constructor for class org.fusesource.stompjms.StompJmsQueueSender
Constructor
StompJmsQueueSession - Class in org.fusesource.stompjms
Jms QueueSession implementation
StompJmsQueueSession(StompJmsConnection, StompChannel, int) - Constructor for class org.fusesource.stompjms.StompJmsQueueSession
Constructor
StompJmsSession - Class in org.fusesource.stompjms
JMS Session implementation
StompJmsSession(StompJmsConnection, StompChannel, int) - Constructor for class org.fusesource.stompjms.StompJmsSession
Constructor
StompJmsStreamMessage - Class in org.fusesource.stompjms.message
A StreamMessage object is used to send a stream of primitive types in the Java programming language.
StompJmsStreamMessage() - Constructor for class org.fusesource.stompjms.message.StompJmsStreamMessage
 
StompJmsTempQueue - Class in org.fusesource.stompjms
TemporaryQueue
StompJmsTempQueue(String) - Constructor for class org.fusesource.stompjms.StompJmsTempQueue
Constructor
StompJmsTempTopic - Class in org.fusesource.stompjms
Temporary Topic
StompJmsTempTopic(String) - Constructor for class org.fusesource.stompjms.StompJmsTempTopic
Constructor
StompJmsTextMessage - Class in org.fusesource.stompjms.message
 
StompJmsTextMessage() - Constructor for class org.fusesource.stompjms.message.StompJmsTextMessage
 
StompJmsTopic - Class in org.fusesource.stompjms
TemporaryQueue
StompJmsTopic(String) - Constructor for class org.fusesource.stompjms.StompJmsTopic
Constructor
StompJmsTopicPublisher - Class in org.fusesource.stompjms
Implementation of a TopicPublisher
StompJmsTopicPublisher(StompJmsSession, StompJmsDestination) - Constructor for class org.fusesource.stompjms.StompJmsTopicPublisher
Constructor
StompJmsTopicSession - Class in org.fusesource.stompjms
Implementation of a TopicSession
StompJmsTopicSession(StompJmsConnection, StompChannel, int) - Constructor for class org.fusesource.stompjms.StompJmsTopicSession
Constructor
StompJmsTopicSubscriber - Class in org.fusesource.stompjms
Implementation of a TopicSubscriber
StompJmsTopicSubscriber(String, StompJmsSession, StompJmsDestination, boolean, String) - Constructor for class org.fusesource.stompjms.StompJmsTopicSubscriber
Constructor
StompSocket - Class in org.fusesource.stompjms.channel
 
StompSocket(SocketFactory, URI, URI) - Constructor for class org.fusesource.stompjms.channel.StompSocket
Connect to a Broker
StompTranslator - Class in org.fusesource.stompjms.channel
Frame translator implementation that uses XStream to convert messages to and from XML and JSON
StompTranslator() - Constructor for class org.fusesource.stompjms.channel.StompTranslator
 
stop() - Method in class org.fusesource.stompjms.channel.StompChannel
 
stop() - Method in class org.fusesource.stompjms.channel.StompSocket
stop and close the socket
stop() - Method in class org.fusesource.stompjms.MessageQueue
 
stop() - Method in class org.fusesource.stompjms.StompJmsConnection
 
stop() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
stop() - Method in class org.fusesource.stompjms.StompJmsSession
 
storeContent() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
 
storeContent() - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
 
storeContent() - Method in class org.fusesource.stompjms.message.StompJmsMessage
serialize the payload
storeContent() - Method in class org.fusesource.stompjms.message.StompJmsObjectMessage
 
storeContent() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
 
storeContent() - Method in class org.fusesource.stompjms.message.StompJmsTextMessage
 
STRING_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
stripBefore(String, char) - Static method in class org.fusesource.stompjms.util.PropertyUtil
Return a String up to and including character
stripPrefix(String, String) - Static method in class org.fusesource.stompjms.util.PropertyUtil
Return a String past a prefix
stripUpto(String, char) - Static method in class org.fusesource.stompjms.util.PropertyUtil
Return a String from to a character
SUBSCRIBE - Static variable in interface org.fusesource.stompjms.channel.Stomp.Commands
 
subscribe(StompJmsDestination, String, String, boolean, boolean) - Method in class org.fusesource.stompjms.channel.StompChannel
 
SUBSCRIPTION - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Ack
 
SUBSCRIPTION - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Message
 

T

TcpBufferedInputStream - Class in org.fusesource.stompjms.channel
An optimized buffered input stream for Tcp
TcpBufferedInputStream(InputStream) - Constructor for class org.fusesource.stompjms.channel.TcpBufferedInputStream
 
TcpBufferedInputStream(InputStream, int) - Constructor for class org.fusesource.stompjms.channel.TcpBufferedInputStream
 
TcpBufferedOutputStream - Class in org.fusesource.stompjms.channel
An optimized buffered outputstream for Tcp
TcpBufferedOutputStream(OutputStream) - Constructor for class org.fusesource.stompjms.channel.TcpBufferedOutputStream
Constructor
TcpBufferedOutputStream(OutputStream, int) - Constructor for class org.fusesource.stompjms.channel.TcpBufferedOutputStream
Creates a new buffered output stream to write data to the specified underlying output stream with the specified buffer size.
TEMP_QUEUE_QUALIFED_PREFIX - Static variable in class org.fusesource.stompjms.StompJmsDestination
 
TEMP_TOPIC_QUALIFED_PREFIX - Static variable in class org.fusesource.stompjms.StompJmsDestination
 
temporary - Variable in class org.fusesource.stompjms.StompJmsDestination
 
text - Variable in class org.fusesource.stompjms.message.StompJmsTextMessage
 
TIMESTAMP - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Message
 
timestamp - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
timeToLive - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
toBuffer() - Method in class org.fusesource.stompjms.channel.StompFrame
 
topic - Variable in class org.fusesource.stompjms.StompJmsDestination
 
TOPIC_QUALIFIED_PREFIX - Static variable in class org.fusesource.stompjms.StompJmsDestination
 
toString() - Method in enum org.fusesource.stompjms.channel.Stomp.Transformations
 
toString() - Method in class org.fusesource.stompjms.channel.StompFrame
 
toString() - Method in class org.fusesource.stompjms.channel.StompSocket
 
toString() - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
 
toString() - Method in class org.fusesource.stompjms.message.StompJmsMapMessage
 
toString() - Method in class org.fusesource.stompjms.message.StompJmsObjectMessage
 
toString() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
 
toString() - Method in class org.fusesource.stompjms.message.StompJmsTextMessage
 
toString() - Method in class org.fusesource.stompjms.MessageQueue
 
toString - Variable in class org.fusesource.stompjms.StompJmsDestination
 
toString() - Method in class org.fusesource.stompjms.StompJmsDestination
 
toString() - Method in class org.fusesource.stompjms.StompJmsQueueBrowser
 
toString() - Method in class org.fusesource.stompjms.util.PropertyExpression
 
TRANSACTION - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers
 
transactionId - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
TRANSFORMATION - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers
 
TRANSFORMATION_ERROR - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers
 
transformDestination(Destination) - Static method in class org.fusesource.stompjms.message.StompJmsMessageTransformation
Creates a an available JMS message from another provider.
transformMessage(Message) - Static method in class org.fusesource.stompjms.message.StompJmsMessageTransformation
Creates a fast shallow copy of the current StompJmsMessage or creates a whole new message instance from an available JMS message from another provider.
TYPE - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Message
 
TYPE - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Send
 
type - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
TypeConversionSupport - Class in org.fusesource.stompjms.channel
 

U

unmarshalPrimitive(DataInputStream) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
unmarshalPrimitiveList(DataInputStream) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
unmarshalPrimitiveMap(DataInputStream) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
unmarshalPrimitiveMap(DataInputStream, int) - Static method in class org.fusesource.stompjms.util.MarshallingSupport
 
UNSUBSCRIBE - Static variable in interface org.fusesource.stompjms.channel.Stomp.Commands
 
unsubscribe(StompJmsDestination, String, boolean, boolean) - Method in class org.fusesource.stompjms.channel.StompChannel
 
unsubscribe(String) - Method in class org.fusesource.stompjms.StompJmsQueueSession
 
unsubscribe(String) - Method in class org.fusesource.stompjms.StompJmsSession
 
USERID - Static variable in interface org.fusesource.stompjms.channel.Stomp.Headers.Message
 

V

valueOf(String) - Static method in enum org.fusesource.stompjms.channel.Stomp.Transformations
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.fusesource.stompjms.message.StompJmsMessage.JmsMsgType
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.fusesource.stompjms.channel.Stomp.Transformations
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.fusesource.stompjms.message.StompJmsMessage.JmsMsgType
Returns an array containing the constants of this enum type, in the order they are declared.

W

waitForMessage() - Method in class org.fusesource.stompjms.StompJmsQueueBrowser
Wait on a semaphore for a fixed amount of time for a message to come in.
write(int) - Method in class org.fusesource.stompjms.channel.TcpBufferedOutputStream
write a byte on to the stream
write(byte[], int, int) - Method in class org.fusesource.stompjms.channel.TcpBufferedOutputStream
write a byte array to the stream
writeBoolean(boolean) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Writes a boolean to the bytes message stream as a 1-byte value.
writeBoolean(boolean) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Writes a boolean to the stream message.
writeBufferFromObject(Object) - Static method in class org.fusesource.stompjms.channel.StompTranslator
 
writeByte(byte) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Writes a byte to the bytes message stream as a 1-byte value.
writeByte(byte) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Writes a byte to the stream message.
writeBytes(byte[]) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Writes a byte array to the bytes message stream.
writeBytes(byte[], int, int) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Writes a portion of a byte array to the bytes message stream.
writeBytes(byte[]) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Writes a byte array field to the stream message.
writeBytes(byte[], int, int) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Writes a portion of a byte array as a byte array field to the stream message.
writeChar(char) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Writes a char to the bytes message stream as a 2-byte value, high byte first.
writeChar(char) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Writes a char to the stream message.
writeDouble(double) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Converts the double argument to a long using the doubleToLongBits method in class Double, and then writes that long value to the bytes message stream as an 8-byte quantity, high byte first.
writeDouble(double) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Writes a double to the stream message.
writeExternal(ObjectOutput) - Method in class org.fusesource.stompjms.jndi.JNDIStorable
 
writeExternal(ObjectOutput) - Method in class org.fusesource.stompjms.StompJmsDestination
 
writeFloat(float) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Converts the float argument to an int using the floatToIntBits method in class Float, and then writes that int value to the bytes message stream as a 4-byte quantity, high byte first.
writeFloat(float) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Writes a float to the stream message.
writeInt(int) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Writes an int to the bytes message stream as four bytes, high byte first.
writeInt(int) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Writes an int to the stream message.
writeLong(long) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Writes a long to the bytes message stream as eight bytes, high byte first.
writeLong(long) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Writes a long to the stream message.
writeObject(Object) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Writes an object to the bytes message stream.
writeObject(Object) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Writes an object to the stream message.
writeObject(DataByteArrayOutputStream, Object) - Static method in class org.fusesource.stompjms.util.IOUtils
 
writeShort(short) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Writes a short to the bytes message stream as two bytes, high byte first.
writeShort(short) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Writes a short to the stream message.
writeString(String) - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
Writes a String to the stream message.
writeStringFromObject(Object) - Static method in class org.fusesource.stompjms.channel.StompTranslator
 
writeUTF(String) - Method in class org.fusesource.stompjms.message.StompJmsBytesMessage
Writes a string to the bytes message stream using UTF-8 encoding in a machine-independent manner.

A B C D E F G H I J L M N O P Q R S T U V W

Copyright © 2010-2011 FuseSource, Corp.. All Rights Reserved.