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

A

ABORT - Static variable in interface org.fusesource.stompjms.client.Constants
 
ABORT_TRANSACTION - Static variable in interface org.fusesource.stompjms.client.Constants
 
ACCEPT_VERSION - Static variable in interface org.fusesource.stompjms.client.Constants
 
ACK - Static variable in interface org.fusesource.stompjms.client.Constants
 
ACK_MODE - Static variable in interface org.fusesource.stompjms.client.Constants
 
ackMessage(AsciiBuffer, AsciiBuffer, AsciiBuffer, Boolean) - Method in class org.fusesource.stompjms.StompChannel
 
acknowledge() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
acknowledgeCallback - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
action() - Method in class org.fusesource.stompjms.client.StompFrame
 
action(AsciiBuffer) - Method in class org.fusesource.stompjms.client.StompFrame
 
add(StompJmsMessageConsumer, boolean, boolean) - Method in class org.fusesource.stompjms.StompJmsSession
 
add(MessageProducer) - Method in class org.fusesource.stompjms.StompJmsSession
 
addContentLengthHeader() - Method in class org.fusesource.stompjms.client.StompFrame
 
addHeader(AsciiBuffer, AsciiBuffer) - Method in class org.fusesource.stompjms.client.StompFrame
 
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
 
addToEnvironment(String, Object) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
AMQ_MESSAGE_TYPE - Static variable in interface org.fusesource.stompjms.client.Constants
This header is used to instruct ActiveMQ to construct the message based with a specific type.
AUTO - Static variable in interface org.fusesource.stompjms.client.Constants
 
await(long, TimeUnit) - Method in class org.fusesource.stompjms.client.future.CallbackFuture
 
await() - Method in class org.fusesource.stompjms.client.future.CallbackFuture
 
await() - Method in interface org.fusesource.stompjms.client.future.Future
 
await(long, TimeUnit) - Method in interface org.fusesource.stompjms.client.future.Future
 

B

BaseService - Class in org.fusesource.stompjms.client.transport
The BaseService provides helpers for dealing async service state.
BaseService() - Constructor for class org.fusesource.stompjms.client.transport.BaseService
 
BaseService.STARTING - Class in org.fusesource.stompjms.client.transport
 
BaseService.STARTING() - Constructor for class org.fusesource.stompjms.client.transport.BaseService.STARTING
 
BaseService.State - Class in org.fusesource.stompjms.client.transport
 
BaseService.State() - Constructor for class org.fusesource.stompjms.client.transport.BaseService.State
 
BaseService.STOPPING - Class in org.fusesource.stompjms.client.transport
 
BaseService.STOPPING() - Constructor for class org.fusesource.stompjms.client.transport.BaseService.STOPPING
 
BEGIN - Static variable in interface org.fusesource.stompjms.client.Constants
 
BEGIN_TRANSACTION - Static variable in interface org.fusesource.stompjms.client.Constants
 
BIG_STRING_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
bind(Name, Object) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
bind(String, Object) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
bindings - Variable in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
blocking(URI) - Static method in class org.fusesource.stompjms.client.Stomp
 
blocking(String) - Static method in class org.fusesource.stompjms.client.Stomp
 
blocking(String, int) - Static method in class org.fusesource.stompjms.client.Stomp
 
blockingExecutor(Executor) - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
blockingExecutor(Executor) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
blockingExecutor(Executor) - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 
blockingExecutor - Variable in class org.fusesource.stompjms.client.transport.SslTransportServer
 
BOOLEAN_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
BROWSER - Static variable in interface org.fusesource.stompjms.client.Constants
 
buffer - Variable in enum org.fusesource.stompjms.message.StompJmsMessage.JmsMsgType
 
buffer - Variable in class org.fusesource.stompjms.StompJmsDestination
 
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> - Class in org.fusesource.stompjms.client.callback
Callback() - Constructor for class org.fusesource.stompjms.client.callback.Callback
 
callback(URI) - Static method in class org.fusesource.stompjms.client.Stomp
 
callback(String) - Static method in class org.fusesource.stompjms.client.Stomp
 
callback(String, int) - Static method in class org.fusesource.stompjms.client.Stomp
 
CallbackFuture<T> - Class in org.fusesource.stompjms.client.future
CallbackFuture() - Constructor for class org.fusesource.stompjms.client.future.CallbackFuture
 
channel - Variable in class org.fusesource.stompjms.client.transport.TcpTransport
 
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.
clearHeaders() - Method in class org.fusesource.stompjms.client.StompFrame
 
clearProperties() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
CLIENT - Static variable in interface org.fusesource.stompjms.client.Constants
 
CLIENT_ID - Static variable in interface org.fusesource.stompjms.client.Constants
 
clone() - Method in class org.fusesource.stompjms.client.StompFrame
 
close() - Method in class org.fusesource.stompjms.client.blocking.Connection
 
close(Runnable) - Method in class org.fusesource.stompjms.client.callback.Connection
 
close() - Method in class org.fusesource.stompjms.client.future.Connection
 
close() - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
close() - Method in class org.fusesource.stompjms.MessageQueue
 
close() - Method in class org.fusesource.stompjms.StompChannel
 
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
 
codec - Variable in class org.fusesource.stompjms.client.transport.TcpTransport
 
COLON - Static variable in interface org.fusesource.stompjms.client.Constants
 
COLON_BYTE - Static variable in interface org.fusesource.stompjms.client.Constants
 
COLON_ESCAPE_SEQ - Static variable in interface org.fusesource.stompjms.client.Constants
 
COMMIT - Static variable in interface org.fusesource.stompjms.client.Constants
 
commit() - Method in class org.fusesource.stompjms.StompJmsSession
 
COMMIT_TRANSACTION - Static variable in interface org.fusesource.stompjms.client.Constants
 
commitTransaction(AsciiBuffer) - Method in class org.fusesource.stompjms.StompChannel
 
compareTo(StompJmsDestination) - Method in class org.fusesource.stompjms.StompJmsDestination
 
composeName(Name, Name) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
composeName(String, String) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
compress(Buffer) - Static method in class org.fusesource.stompjms.util.IOUtils
Compress the buffer
connect() - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
connect(Callback<Connection>) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
CONNECT - Static variable in interface org.fusesource.stompjms.client.Constants
 
connect() - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 
connect() - Method in class org.fusesource.stompjms.StompChannel
 
CONNECTED - Static variable in interface org.fusesource.stompjms.client.Constants
 
connected(SocketChannel) - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
connected(SocketChannel) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
connectedFrame() - Method in class org.fusesource.stompjms.client.blocking.Connection
 
connectedFrame() - Method in class org.fusesource.stompjms.client.callback.Connection
 
connectedFrame() - Method in class org.fusesource.stompjms.client.future.Connection
 
connecting(URI, URI) - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
connecting(URI, URI) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
Connection - Class in org.fusesource.stompjms.client.blocking
Connection - Class in org.fusesource.stompjms.client.callback
Connection - Class in org.fusesource.stompjms.client.future
connection() - Method in class org.fusesource.stompjms.StompChannel
 
ConnectionBuilder - Class in org.fusesource.stompjms.client.blocking
ConnectionBuilder(ConnectionBuilder) - Constructor for class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
ConnectionBuilder - Class in org.fusesource.stompjms.client.callback
ConnectionBuilder(URI) - Constructor for class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
ConnectionBuilder - Class in org.fusesource.stompjms.client.future
ConnectionBuilder(ConnectionBuilder) - Constructor for class org.fusesource.stompjms.client.future.ConnectionBuilder
 
Constants - Interface in org.fusesource.stompjms.client
content() - Method in class org.fusesource.stompjms.client.StompFrame
 
content(Buffer) - Method in class org.fusesource.stompjms.client.StompFrame
 
CONTENT_LENGTH - Static variable in interface org.fusesource.stompjms.client.Constants
 
CONTENT_TYPE - Static variable in interface org.fusesource.stompjms.client.Constants
 
contentAsString() - Method in class org.fusesource.stompjms.client.StompFrame
 
convert(StompFrame) - Static method in class org.fusesource.stompjms.util.StompTranslator
 
convert(Object, Class) - Static method in class org.fusesource.stompjms.util.TypeConversionSupport
 
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
 
copy() - Method in class org.fusesource.stompjms.StompChannel
 
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.client.Constants
 
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
 
createConnectionFactory(String, Hashtable) - Method in class org.fusesource.stompjms.jndi.StompJmsInitialContextFactory
 
createConnectionFactory(Hashtable) - Method in class org.fusesource.stompjms.jndi.StompJmsInitialContextFactory
Factory method to create a new connection factory from the given environment
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
 
createContext(Hashtable, Map<String, Object>) - Method in class org.fusesource.stompjms.jndi.StompJmsInitialContextFactory
 
CREATED - Static variable in class org.fusesource.stompjms.client.transport.BaseService
 
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
 
createEntry(String) - Method in class org.fusesource.stompjms.jndi.LazyCreateContext
 
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.jndi.StompJmsInitialContextFactory
Factory method to create new Queue instances
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
 
createSubcontext(Name) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
createSubcontext(String) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
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.jndi.StompJmsInitialContextFactory
Factory method to create new Topic instances
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
 
createTransport(URI) - Static method in class org.fusesource.stompjms.client.transport.SslTransport
Allows subclasses of TcpTransportFactory to create custom instances of TcpTransport.
createTransport() - Method in class org.fusesource.stompjms.client.transport.SslTransportServer
 
createTransport() - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
createTransportServer(URI) - Static method in class org.fusesource.stompjms.client.transport.SslTransportServer
 

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
 
decodeHeader(Buffer) - Static method in class org.fusesource.stompjms.client.StompFrame
 
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.client.Constants
 
destination - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
destroySubcontext(Name) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
destroySubcontext(String) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
disableMessageId - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
disableTimestamp - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
DISCONNECT - Static variable in interface org.fusesource.stompjms.client.Constants
 
dispatchQueue(DispatchQueue) - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
dispatchQueue(DispatchQueue) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
dispatchQueue(DispatchQueue) - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 
dispatchQueue - Variable in class org.fusesource.stompjms.client.transport.TcpTransport
 
DOUBLE_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
drainInbound() - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
drainInbound() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
drainOutbound() - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
drainOutbound() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 

E

encodeHeader(String) - Static method in class org.fusesource.stompjms.client.StompFrame
 
encodeString(String) - Static method in class org.fusesource.stompjms.message.StompJmsMessage
 
END - Static variable in interface org.fusesource.stompjms.client.Constants
 
enqueue(StompJmsMessage) - Method in class org.fusesource.stompjms.MessageQueue
 
enqueueFirst(StompJmsMessage) - Method in class org.fusesource.stompjms.MessageQueue
 
environment - Variable in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
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.client.Constants
 
errorMessage() - Method in class org.fusesource.stompjms.client.StompFrame
 
ESCAPE_BYTE - Static variable in interface org.fusesource.stompjms.client.Constants
 
ESCAPE_ESCAPE_SEQ - Static variable in interface org.fusesource.stompjms.client.Constants
 
evaluate(StompJmsMessage) - Method in class org.fusesource.stompjms.util.PropertyExpression
 
EXPIRATION_TIME - Static variable in interface org.fusesource.stompjms.client.Constants
 

F

failure(Throwable) - Method in class org.fusesource.stompjms.client.callback.Callback
 
failure(Throwable) - Method in class org.fusesource.stompjms.client.future.CallbackFuture
 
FALSE - Static variable in interface org.fusesource.stompjms.client.Constants
 
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.client.StompProtocolCodec
 
flush() - Method in interface org.fusesource.stompjms.client.transport.ProtocolCodec
Attempts to complete the previous write which did not complete.
flush() - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
flush() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
frame - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
freeze() - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
full() - Method in class org.fusesource.stompjms.client.callback.Connection
 
full() - Method in class org.fusesource.stompjms.client.StompProtocolCodec
 
full() - Method in interface org.fusesource.stompjms.client.transport.ProtocolCodec
Is the codec's buffer full?
full() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
full() - Method in interface org.fusesource.stompjms.client.transport.Transport
 
Future<T> - Interface in org.fusesource.stompjms.client.future
future(URI) - Static method in class org.fusesource.stompjms.client.Stomp
 
future(String) - Static method in class org.fusesource.stompjms.client.Stomp
 
future(String, int) - Static method in class org.fusesource.stompjms.client.Stomp
 

G

getAckMode() - Method in class org.fusesource.stompjms.StompChannel
 
getAcknowledgeCallback() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getAcknowledgeMode() - Method in class org.fusesource.stompjms.StompJmsSession
 
getAllPropertyNames() - Method in class org.fusesource.stompjms.message.StompJmsMessage
return all property names, including standard JMS properties and JMSX properties
getBacklog() - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
getBlockingExecutor() - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
getBlockingThreadPool() - Static method in class org.fusesource.stompjms.client.Stomp
 
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
 
getBoundAddress() - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
getBoundAddress() - Method in interface org.fusesource.stompjms.client.transport.TransportServer
 
getBrokerURI() - Method in class org.fusesource.stompjms.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.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
 
getConnectAddress() - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
getConnectAddress() - Method in interface org.fusesource.stompjms.client.transport.TransportServer
 
getConnection() - Method in class org.fusesource.stompjms.StompJmsSession
 
getConnectionFactoryNames(Map) - Method in class org.fusesource.stompjms.jndi.StompJmsInitialContextFactory
 
getConnectionPrefix() - Method in class org.fusesource.stompjms.jndi.StompJmsInitialContextFactory
 
getConsumerId() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
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() - 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
 
getDispatchQueue() - Method in class org.fusesource.stompjms.client.callback.Connection
 
getDispatchQueue() - Method in class org.fusesource.stompjms.client.transport.BaseService
 
getDispatchQueue() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
getDispatchQueue() - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
getDispatchQueue() - Method in interface org.fusesource.stompjms.client.transport.Transport
Returns the dispatch queue used by the transport
getDispatchQueue() - Method in interface org.fusesource.stompjms.client.transport.TransportServer
Returns the dispatch queue used by the transport
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.
getEnvironment() - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
getExceptionListener() - Method in class org.fusesource.stompjms.StompJmsConnection
 
getFailure() - Method in class org.fusesource.stompjms.client.callback.Connection
 
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
 
getFrame() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getHeader(AsciiBuffer) - Method in class org.fusesource.stompjms.client.StompFrame
 
getId() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
getInitialContext(Hashtable) - Method in class org.fusesource.stompjms.jndi.StompJmsInitialContextFactory
 
getInitialContext(Hashtable) - Method in class org.fusesource.stompjms.jndi.WasStompJmsInitialContextFactory
 
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
 
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
 
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.
getJMSXPropertyNames() - Method in class org.fusesource.stompjms.StompJmsConnectionMetaData
Gets an enumeration of the JMSX property names.
getKey() - Method in class org.fusesource.stompjms.client.StompFrame.HeaderEntry
 
getLastReadSize() - Method in class org.fusesource.stompjms.client.StompProtocolCodec
 
getLastReadSize() - Method in interface org.fusesource.stompjms.client.transport.ProtocolCodec
 
getLastWriteSize() - Method in class org.fusesource.stompjms.client.StompProtocolCodec
 
getLastWriteSize() - Method in interface org.fusesource.stompjms.client.transport.ProtocolCodec
 
getListener() - Method in class org.fusesource.stompjms.StompChannel
 
getLocalAddress() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
getLocalAddress() - Method in interface org.fusesource.stompjms.client.transport.Transport
 
getLocalURI() - Method in class org.fusesource.stompjms.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
 
getMaxReadRate() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
getMaxWriteRate() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
getMessageID() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
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
 
getNameInNamespace() - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
getNameParser(Name) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
getNameParser(String) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
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.StompChannel
 
getPassword() - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
getPeerX509Certificates() - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
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
 
getProtocolCodec() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
getProtocolCodec() - Method in interface org.fusesource.stompjms.client.transport.Transport
 
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
 
getReadBufferSize() - Method in class org.fusesource.stompjms.client.StompProtocolCodec
 
getReadBufferSize() - Method in interface org.fusesource.stompjms.client.transport.ProtocolCodec
 
getReadCounter() - Method in class org.fusesource.stompjms.client.StompProtocolCodec
 
getReadCounter() - Method in interface org.fusesource.stompjms.client.transport.ProtocolCodec
 
getReceive_buffer_size() - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
getReceiveBufferSize() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
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.client.transport.TcpTransport
 
getRemoteAddress() - Method in interface org.fusesource.stompjms.client.transport.Transport
 
getSendBufferSize() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
getServiceState() - Method in class org.fusesource.stompjms.client.transport.BaseService
 
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
 
getSocketAddress() - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
getSocketAddress() - Method in interface org.fusesource.stompjms.client.transport.TransportServer
 
getSocketChannel() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
getSSLContext() - Method in class org.fusesource.stompjms.client.transport.SslTransportServer
 
getSSLSession() - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
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
 
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
 
getTrafficClass() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
getTransacted() - Method in class org.fusesource.stompjms.StompJmsSession
 
getTransactionId() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
getTransportListener() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
getTransportListener() - Method in interface org.fusesource.stompjms.client.transport.Transport
Returns the current transport listener
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
 
getTypeId() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
getTypeId() - Method in interface org.fusesource.stompjms.client.transport.Transport
 
getUserName() - Method in class org.fusesource.stompjms.StompChannel
 
getUsername() - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
getValue() - Method in class org.fusesource.stompjms.client.StompFrame.HeaderEntry
 
getWriteBufferSize() - Method in class org.fusesource.stompjms.client.StompProtocolCodec
 
getWriteBufferSize() - Method in interface org.fusesource.stompjms.client.transport.ProtocolCodec
 
getWriteCounter() - Method in class org.fusesource.stompjms.client.StompProtocolCodec
 
getWriteCounter() - Method in interface org.fusesource.stompjms.client.transport.ProtocolCodec
 

H

handleSocket(SocketChannel) - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
handshake() - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
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
 
headerList() - Method in class org.fusesource.stompjms.client.StompFrame
 
headerMap() - Method in class org.fusesource.stompjms.client.StompFrame
 
host(String) - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
host(String) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
HOST - Static variable in interface org.fusesource.stompjms.client.Constants
 
host(String) - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 

I

ID - Static variable in interface org.fusesource.stompjms.client.Constants
 
incrementRedeliveryCounter() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
INDIVIDUAL - Static variable in interface org.fusesource.stompjms.client.Constants
 
inflate(Buffer) - Static method in class org.fusesource.stompjms.util.IOUtils
Inflate a compressed buffer
init() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
initializeCodec() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
INSTANCE - Static variable in class org.fusesource.stompjms.StompJmsConnectionMetaData
 
INTEGER_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
internalBind(String, Object) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
internalBind is intended for use only during setup or possibly by suitably synchronized superclasses.
IOUtils - Class in org.fusesource.stompjms.util
Utilities for ByteBuffers
IOUtils() - Constructor for class org.fusesource.stompjms.util.IOUtils
 
IPTOS_LOWCOST - Static variable in class org.fusesource.stompjms.client.transport.TcpTransport
 
IPTOS_LOWDELAY - Static variable in class org.fusesource.stompjms.client.transport.TcpTransport
 
IPTOS_RELIABILITY - Static variable in class org.fusesource.stompjms.client.transport.TcpTransport
 
IPTOS_THROUGHPUT - Static variable in class org.fusesource.stompjms.client.transport.TcpTransport
 
is_empty() - Method in class org.fusesource.stompjms.client.StompProtocolCodec
 
isBrowser() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
isClosed() - Method in class org.fusesource.stompjms.MessageQueue
 
isConnected() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
isConnected() - Method in interface org.fusesource.stompjms.client.transport.Transport
 
isDisposed() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
isDisposed() - Method in interface org.fusesource.stompjms.client.transport.Transport
 
isDurableSubscription() - Method in class org.fusesource.stompjms.StompJmsDurableTopicSubscriber
 
isDurableSubscription() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
isEmpty() - Method in class org.fusesource.stompjms.MessageQueue
 
isFatal() - Method in exception org.fusesource.stompjms.client.ProtocolException
 
isFaultTolerant() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
isFaultTolerant() - Method in interface org.fusesource.stompjms.client.transport.Transport
Indicates if the transport can handle faults
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.client.transport.BaseService.State
 
isStarted() - Method in class org.fusesource.stompjms.StompChannel
 
isStarted() - Method in class org.fusesource.stompjms.StompJmsSession
 
isTemporary() - Method in class org.fusesource.stompjms.StompJmsDestination
 
isTopic() - Method in class org.fusesource.stompjms.StompJmsDestination
 
isUseLocalHost() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
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
 

K

key - Variable in class org.fusesource.stompjms.client.StompFrame.HeaderEntry
 
keyManagers - Variable in class org.fusesource.stompjms.client.transport.SslTransportServer
 

L

LazyCreateContext - Class in org.fusesource.stompjms.jndi
Allows users to dynamically create items
LazyCreateContext() - Constructor for class org.fusesource.stompjms.jndi.LazyCreateContext
 
lazyCreateProperties() - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
length - Variable in class org.fusesource.stompjms.message.StompJmsBytesMessage
 
list(String) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
list(Name) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
LIST_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
listBindings(String) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
listBindings(Name) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
listener - Variable in class org.fusesource.stompjms.client.transport.TcpTransport
 
loadClass(Object, String) - Static method in class org.fusesource.stompjms.jndi.JNDIReferenceFactory
Retrieve the class loader for a named class
localLocation - Variable in class org.fusesource.stompjms.client.transport.TcpTransport
 
localURI(URI) - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
localURI(URI) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
localURI(URI) - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 
login(String) - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
login(String) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
LOGIN - Static variable in interface org.fusesource.stompjms.client.Constants
 
login(String) - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 
LONG_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
lookup(String) - Method in class org.fusesource.stompjms.jndi.LazyCreateContext
 
lookup(String) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
lookup(Name) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
lookupLink(String) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
lookupLink(Name) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
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
 
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
 
maxReadRate(int) - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
maxReadRate(int) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
maxReadRate(int) - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 
maxWriteRate(int) - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
maxWriteRate(int) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
maxWriteRate(int) - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 
MESSAGE - Static variable in interface org.fusesource.stompjms.client.Constants
 
MESSAGE_HEADER - Static variable in interface org.fusesource.stompjms.client.Constants
 
MESSAGE_ID - Static variable in interface org.fusesource.stompjms.client.Constants
 
MessageQueue - Class in org.fusesource.stompjms
 
MessageQueue() - Constructor for class org.fusesource.stompjms.MessageQueue
 
mime - Variable in enum org.fusesource.stompjms.message.StompJmsMessage.JmsMsgType
 

N

NAME_PARSER - Static variable in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
NameParserImpl - Class in org.fusesource.stompjms.jndi
A default implementation of NameParser
NameParserImpl() - Constructor for class org.fusesource.stompjms.jndi.NameParserImpl
 
narrow(Class<T>) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
narrow(Class<T>) - Method in interface org.fusesource.stompjms.client.transport.Transport
 
newContext() - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
NEWLINE - Static variable in interface org.fusesource.stompjms.client.Constants
 
NEWLINE_BYTE - Static variable in interface org.fusesource.stompjms.client.Constants
 
NEWLINE_ESCAPE_SEQ - Static variable in interface org.fusesource.stompjms.client.Constants
 
nextElement() - Method in class org.fusesource.stompjms.StompJmsQueueBrowser
 
nextId() - Method in class org.fusesource.stompjms.client.blocking.Connection
 
nextId(String) - Method in class org.fusesource.stompjms.client.blocking.Connection
 
nextId() - Method in class org.fusesource.stompjms.client.callback.Connection
 
nextId(String) - Method in class org.fusesource.stompjms.client.callback.Connection
 
nextId() - Method in class org.fusesource.stompjms.client.future.Connection
 
nextId(String) - Method in class org.fusesource.stompjms.client.future.Connection
 
nextId() - Method in class org.fusesource.stompjms.StompChannel
 
NO_DATA - Static variable in class org.fusesource.stompjms.client.StompFrame
 
notifyMessageAvailable() - Method in class org.fusesource.stompjms.StompJmsQueueBrowser
 
NULL - Static variable in interface org.fusesource.stompjms.client.Constants
 
NULL - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
NULL_BYTE - Static variable in interface org.fusesource.stompjms.client.Constants
 

O

object - Variable in class org.fusesource.stompjms.message.StompJmsObjectMessage
 
offer(StompFrame) - Method in class org.fusesource.stompjms.client.callback.Connection
 
offer(Object) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
offer(Object) - Method in interface org.fusesource.stompjms.client.transport.Transport
A one way asynchronous send of a command.
onAccept(Transport) - Method in interface org.fusesource.stompjms.client.transport.TransportServerListener
 
onAcceptError(Exception) - Method in interface org.fusesource.stompjms.client.transport.TransportServerListener
 
onConnected() - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
onConnected() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
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.StompChannel
 
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
 
onRefill() - Method in interface org.fusesource.stompjms.client.transport.TransportListener
transport can now accept more commands for transmission.
onSend() - Method in class org.fusesource.stompjms.message.StompJmsMessage
Send operation event listener.
onSend() - Method in class org.fusesource.stompjms.message.StompJmsStreamMessage
 
onTransportCommand(Object) - Method in interface org.fusesource.stompjms.client.transport.TransportListener
called to process a command
onTransportConnected() - Method in interface org.fusesource.stompjms.client.transport.TransportListener
The transport has been connected.
onTransportDisconnected() - Method in interface org.fusesource.stompjms.client.transport.TransportListener
The transport has suffered a disconnection from which it hopes to recover
onTransportFailure(IOException) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
onTransportFailure(IOException) - Method in interface org.fusesource.stompjms.client.transport.TransportListener
An unrecoverable exception has occured on the transport
org.fusesource.stompjms - package org.fusesource.stompjms
 
org.fusesource.stompjms.client - package org.fusesource.stompjms.client
 
org.fusesource.stompjms.client.blocking - package org.fusesource.stompjms.client.blocking
 
org.fusesource.stompjms.client.callback - package org.fusesource.stompjms.client.callback
 
org.fusesource.stompjms.client.future - package org.fusesource.stompjms.client.future
 
org.fusesource.stompjms.client.transport - package org.fusesource.stompjms.client.transport
 
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

parse(String) - Method in class org.fusesource.stompjms.jndi.NameParserImpl
 
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(String) - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
passcode(String) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
PASSCODE - Static variable in interface org.fusesource.stompjms.client.Constants
 
passcode(String) - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 
peek() - Method in class org.fusesource.stompjms.MessageQueue
 
PERSISTENT - Static variable in interface org.fusesource.stompjms.client.Constants
 
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
 
PRIORITY - Static variable in interface org.fusesource.stompjms.client.Constants
 
priority - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
PROPERTIES - Static variable in interface org.fusesource.stompjms.client.Constants
 
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
 
protocol - Variable in class org.fusesource.stompjms.client.transport.SslTransportServer
 
protocol(String) - Method in class org.fusesource.stompjms.client.transport.SslTransportServer
 
ProtocolCodec - Interface in org.fusesource.stompjms.client.transport
Interface to encode and decode commands in and out of a a non blocking channel.
ProtocolCodec.BufferState - Enum in org.fusesource.stompjms.client.transport
 
ProtocolException - Exception in org.fusesource.stompjms.client
ProtocolException() - Constructor for exception org.fusesource.stompjms.client.ProtocolException
 
ProtocolException(String) - Constructor for exception org.fusesource.stompjms.client.ProtocolException
 
ProtocolException(String, boolean) - Constructor for exception org.fusesource.stompjms.client.ProtocolException
 
ProtocolException(String, boolean, Throwable) - Constructor for exception org.fusesource.stompjms.client.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
 

Q

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

R

rateLimitingChannel - Variable in class org.fusesource.stompjms.client.transport.TcpTransport
 
read() - Method in class org.fusesource.stompjms.client.StompProtocolCodec
 
read() - Method in interface org.fusesource.stompjms.client.transport.ProtocolCodec
Non-blocking channel based decoding.
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).
readChannel() - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
readChannel() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
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.util.StompTranslator
 
readOnlyBody - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
ReadOnlyContext - Class in org.fusesource.stompjms.jndi
A read-only Context

This version assumes it and all its subcontext are read-only and any attempt to modify (e.g.

ReadOnlyContext() - Constructor for class org.fusesource.stompjms.jndi.ReadOnlyContext
 
ReadOnlyContext(Hashtable) - Constructor for class org.fusesource.stompjms.jndi.ReadOnlyContext
 
ReadOnlyContext(Hashtable, Map<String, Object>) - Constructor for class org.fusesource.stompjms.jndi.ReadOnlyContext
 
ReadOnlyContext(Hashtable, Map, String) - Constructor for class org.fusesource.stompjms.jndi.ReadOnlyContext
 
ReadOnlyContext(ReadOnlyContext, Hashtable) - Constructor for class org.fusesource.stompjms.jndi.ReadOnlyContext
 
ReadOnlyContext(ReadOnlyContext, Hashtable<String, Object>, String) - Constructor for class org.fusesource.stompjms.jndi.ReadOnlyContext
 
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.
rebind(Name, Object) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
rebind(String, Object) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
RECEIPT - Static variable in interface org.fusesource.stompjms.client.Constants
 
RECEIPT_ID - Static variable in interface org.fusesource.stompjms.client.Constants
 
RECEIPT_REQUESTED - Static variable in interface org.fusesource.stompjms.client.Constants
 
receive() - Method in class org.fusesource.stompjms.client.blocking.Connection
 
receive(Callback<StompFrame>) - Method in class org.fusesource.stompjms.client.callback.Connection
 
receive() - Method in class org.fusesource.stompjms.client.future.Connection
 
receive() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
receive(long) - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
receiveBufferSize(int) - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
receiveBufferSize(int) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
receiveBufferSize(int) - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 
receiveNoWait() - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
reconnect(URI) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
reconnect(URI) - Method in interface org.fusesource.stompjms.client.transport.Transport
reconnect to another location
recover() - Method in class org.fusesource.stompjms.StompJmsSession
 
REDELIVERED - Static variable in interface org.fusesource.stompjms.client.Constants
 
redeliveryCounter - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
refiller(Runnable) - Method in class org.fusesource.stompjms.client.callback.Connection
 
remainingBytes - Variable in class org.fusesource.stompjms.message.StompJmsStreamMessage
 
remoteLocation - Variable in class org.fusesource.stompjms.client.transport.TcpTransport
 
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
 
removeFromEnvironment(String) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
removeProperty(String) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
removeSession(StompJmsSession) - Method in class org.fusesource.stompjms.StompJmsConnection
 
rename(Name, Name) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
rename(String, String) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
REPLY_TO - Static variable in interface org.fusesource.stompjms.client.Constants
 
request(StompFrame) - Method in class org.fusesource.stompjms.client.blocking.Connection
 
request(StompFrame, Callback<StompFrame>) - Method in class org.fusesource.stompjms.client.callback.Connection
 
request(StompFrame) - Method in class org.fusesource.stompjms.client.future.Connection
 
REQUEST_ID - Static variable in interface org.fusesource.stompjms.client.Constants
 
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
 
resolveHostName(String) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
resolveHostName() - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
resolveProxyClass(String[]) - Method in class org.fusesource.stompjms.util.ClassLoadingAwareObjectInputStream
 
RESPONSE_ID - Static variable in interface org.fusesource.stompjms.client.Constants
 
resume() - Method in class org.fusesource.stompjms.client.blocking.Connection
 
resume() - Method in class org.fusesource.stompjms.client.callback.Connection
 
resume() - Method in class org.fusesource.stompjms.client.future.Connection
 
resume() - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
resume() - Method in interface org.fusesource.stompjms.client.transport.TransportServer
resume accepting new transports
resumeRead() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
resumeRead() - Method in interface org.fusesource.stompjms.client.transport.Transport
resume delivery of commands.
resumeWrite() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
rollback(AsciiBuffer) - Method in class org.fusesource.stompjms.MessageQueue
 
rollback(AsciiBuffer) - Method in class org.fusesource.stompjms.StompJmsMessageConsumer
 
rollback() - Method in class org.fusesource.stompjms.StompJmsSession
 
rollbackTransaction(AsciiBuffer) - Method in class org.fusesource.stompjms.StompChannel
 
run() - Method in class org.fusesource.stompjms.StompJmsSession
 

S

SCHEME_MAPPINGS - Static variable in class org.fusesource.stompjms.client.transport.SslTransport
 
SELECTOR - Static variable in interface org.fusesource.stompjms.client.Constants
 
send(StompFrame) - Method in class org.fusesource.stompjms.client.blocking.Connection
 
send(StompFrame, Callback<Void>) - Method in class org.fusesource.stompjms.client.callback.Connection
 
SEND - Static variable in interface org.fusesource.stompjms.client.Constants
 
send(StompFrame) - Method in class org.fusesource.stompjms.client.future.Connection
 
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
 
sendBufferSize(int) - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
sendBufferSize(int) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
sendBufferSize(int) - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 
sendFrame(StompFrame) - Method in class org.fusesource.stompjms.StompChannel
 
sendMessage(StompJmsMessage, AsciiBuffer, boolean) - Method in class org.fusesource.stompjms.StompChannel
 
sendRequest(StompFrame) - Method in class org.fusesource.stompjms.StompChannel
 
SEPARATOR - Static variable in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
SESSION - Static variable in interface org.fusesource.stompjms.client.Constants
 
session - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
sessionId() - Method in class org.fusesource.stompjms.StompChannel
 
setAcceptListener(TransportServerListener) - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
setAcceptListener(TransportServerListener) - Method in interface org.fusesource.stompjms.client.transport.TransportServer
Registers an TransportAcceptListener which is notified of accepted channels.
setAckMode(String) - Method in class org.fusesource.stompjms.StompChannel
 
setAcknowledgeCallback(Runnable) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setBacklog(int) - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
setBlockingExecutor(Executor) - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
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.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.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
 
setConnectionPrefix(String) - Method in class org.fusesource.stompjms.jndi.StompJmsInitialContextFactory
 
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
 
setDispatchQueue(DispatchQueue) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
setDispatchQueue(DispatchQueue) - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
setDispatchQueue(DispatchQueue) - Method in interface org.fusesource.stompjms.client.transport.Transport
Sets the dispatch queue used by the transport
setDispatchQueue(DispatchQueue) - Method in interface org.fusesource.stompjms.client.transport.TransportServer
Sets the dispatch queue used by the transport
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.StompChannel
 
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
 
setFrame(StompFrame) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setHeaders(ArrayList<StompFrame.HeaderEntry>) - Method in class org.fusesource.stompjms.client.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
 
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
 
setKeyManagers(KeyManager[]) - Method in class org.fusesource.stompjms.client.transport.SslTransportServer
 
setListener(StompJmsMessageListener) - Method in class org.fusesource.stompjms.StompChannel
 
setLocalURI(URI) - Method in class org.fusesource.stompjms.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
 
setMaxReadRate(int) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
setMaxWriteRate(int) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
setMessageID(AsciiBuffer) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
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.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
setProtocolCodec(ProtocolCodec) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
setProtocolCodec(ProtocolCodec) - Method in interface org.fusesource.stompjms.client.transport.Transport
Sets the protocol codec for the transport
setReadableByteChannel(ReadableByteChannel) - Method in class org.fusesource.stompjms.client.StompProtocolCodec
 
setReadableByteChannel(ReadableByteChannel) - Method in interface org.fusesource.stompjms.client.transport.ProtocolCodec
 
setReadOnlyBody(boolean) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setReadOnlyProperties(boolean) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setReceive_buffer_size(int) - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
setReceiveBufferSize(int) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
setRedelivered(boolean) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setRedeliveryCounter(int) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setSendBufferSize(int) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
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
 
setSSLContext(SSLContext) - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
setSSLContext(SSLContext) - Method in class org.fusesource.stompjms.client.transport.SslTransportServer
 
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
 
setText(String) - Method in class org.fusesource.stompjms.message.StompJmsTextMessage
 
setTimeToLive(long) - Method in class org.fusesource.stompjms.StompJmsMessageProducer
 
setTrafficClass(int) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
setTransactionId(AsciiBuffer) - Method in class org.fusesource.stompjms.message.StompJmsMessage
 
setTransportListener(TransportListener) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
setTransportListener(TransportListener) - Method in interface org.fusesource.stompjms.client.transport.Transport
Registers an inbound command listener
setTransportOption(Map<String, String>) - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
setTrustManagers(TrustManager[]) - Method in class org.fusesource.stompjms.client.transport.SslTransportServer
 
setUseLocalHost(boolean) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
Sets whether 'localhost' or the actual local host name should be used to make local connections.
setUserName(String) - Method in class org.fusesource.stompjms.StompChannel
 
setUsername(String) - Method in class org.fusesource.stompjms.StompJmsConnectionFactory
 
setWritableByteChannel(WritableByteChannel) - Method in class org.fusesource.stompjms.client.StompProtocolCodec
 
setWritableByteChannel(WritableByteChannel) - Method in interface org.fusesource.stompjms.client.transport.ProtocolCodec
 
SHORT_TYPE - Static variable in class org.fusesource.stompjms.util.MarshallingSupport
 
size() - Method in class org.fusesource.stompjms.client.StompFrame
 
size() - Method in class org.fusesource.stompjms.MessageQueue
 
socketState - Variable in class org.fusesource.stompjms.client.transport.TcpTransport
 
sslContext(SSLContext) - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
sslContext(SSLContext) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
sslContext(SSLContext) - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 
sslContext - Variable in class org.fusesource.stompjms.client.transport.SslTransportServer
 
SslTransport - Class in org.fusesource.stompjms.client.transport
An SSL Transport for secure communications.
SslTransport() - Constructor for class org.fusesource.stompjms.client.transport.SslTransport
 
SslTransportServer - Class in org.fusesource.stompjms.client.transport
 
SslTransportServer(URI) - Constructor for class org.fusesource.stompjms.client.transport.SslTransportServer
 
start(Runnable) - Method in class org.fusesource.stompjms.client.transport.BaseService
 
start(Runnable) - Method in class org.fusesource.stompjms.client.transport.SslTransportServer
 
start() - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
start(Runnable) - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
start(Runnable) - Method in interface org.fusesource.stompjms.client.transport.Transport
Starts the service.
start(Runnable) - Method in interface org.fusesource.stompjms.client.transport.TransportServer
Starts the service.
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
 
STARTED - Static variable in class org.fusesource.stompjms.client.transport.BaseService
 
startTransaction() - Method in class org.fusesource.stompjms.StompChannel
 
Stomp - Class in org.fusesource.stompjms.client
StompChannel - Class in org.fusesource.stompjms
 
StompChannel() - Constructor for class org.fusesource.stompjms.StompChannel
 
StompFrame - Class in org.fusesource.stompjms.client
Represents all the data in a STOMP frame.
StompFrame() - Constructor for class org.fusesource.stompjms.client.StompFrame
 
StompFrame(AsciiBuffer) - Constructor for class org.fusesource.stompjms.client.StompFrame
 
StompFrame.HeaderEntry - Class in org.fusesource.stompjms.client
 
StompFrame.HeaderEntry(AsciiBuffer, AsciiBuffer) - Constructor for class org.fusesource.stompjms.client.StompFrame.HeaderEntry
 
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
 
StompJmsDurableTopicSubscriber - Class in org.fusesource.stompjms
Implementation of a TopicSubscriber
StompJmsDurableTopicSubscriber(AsciiBuffer, StompJmsSession, StompJmsDestination, boolean, String) - Constructor for class org.fusesource.stompjms.StompJmsDurableTopicSubscriber
 
StompJmsExceptionSupport - Class in org.fusesource.stompjms
Create those nice, old fashioned JMS Exceptions
StompJmsInitialContextFactory - Class in org.fusesource.stompjms.jndi
A factory of the StompJms InitialContext which contains ConnectionFactory instances as well as a child context called destinations which contain all of the current active destinations, in child context depending on the QoS such as transient or durable and queue or topic.
StompJmsInitialContextFactory() - Constructor for class org.fusesource.stompjms.jndi.StompJmsInitialContextFactory
 
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(AsciiBuffer, 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, AsciiBuffer, 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(AsciiBuffer, 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
StompProtocolCodec - Class in org.fusesource.stompjms.client
StompProtocolCodec() - Constructor for class org.fusesource.stompjms.client.StompProtocolCodec
 
StompTranslator - Class in org.fusesource.stompjms.util
Frame translator implementation that uses XStream to convert messages to and from XML and JSON
StompTranslator() - Constructor for class org.fusesource.stompjms.util.StompTranslator
 
stop(Runnable) - Method in class org.fusesource.stompjms.client.transport.BaseService
 
stop() - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
stop(Runnable) - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
stop(Runnable) - Method in interface org.fusesource.stompjms.client.transport.Transport
Stops the service.
stop(Runnable) - Method in interface org.fusesource.stompjms.client.transport.TransportServer
Stops the service.
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
 
STOPPED - Static variable in class org.fusesource.stompjms.client.transport.BaseService
 
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.client.Constants
 
subscribe(StompJmsDestination, AsciiBuffer, AsciiBuffer, boolean, boolean, boolean) - Method in class org.fusesource.stompjms.StompChannel
 
SUBSCRIPTION - Static variable in interface org.fusesource.stompjms.client.Constants
 
success(T) - Method in class org.fusesource.stompjms.client.callback.Callback
 
success(T) - Method in class org.fusesource.stompjms.client.future.CallbackFuture
 
suspend() - Method in class org.fusesource.stompjms.client.blocking.Connection
 
suspend() - Method in class org.fusesource.stompjms.client.callback.Connection
 
suspend() - Method in class org.fusesource.stompjms.client.future.Connection
 
suspend() - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
suspend() - Method in interface org.fusesource.stompjms.client.transport.TransportServer
suspend accepting new transports
suspendRead() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
suspendRead() - Method in interface org.fusesource.stompjms.client.transport.Transport
suspend delivery of commands.
suspendWrite() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 

T

TcpTransport - Class in org.fusesource.stompjms.client.transport
An implementation of the Transport interface using raw tcp/ip
TcpTransport() - Constructor for class org.fusesource.stompjms.client.transport.TcpTransport
 
TcpTransportServer - Class in org.fusesource.stompjms.client.transport
A TCP based implementation of TransportServer
TcpTransportServer(URI) - Constructor for class org.fusesource.stompjms.client.transport.TcpTransportServer
 
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.client.Constants
 
timeToLive - Variable in class org.fusesource.stompjms.StompJmsMessageProducer
 
toBuffer() - Method in class org.fusesource.stompjms.client.StompFrame
 
toBuffer(boolean) - Method in class org.fusesource.stompjms.client.StompFrame
 
toBuffer() - Method in class org.fusesource.stompjms.StompJmsDestination
 
topic - Variable in class org.fusesource.stompjms.StompJmsDestination
 
TOPIC_QUALIFIED_PREFIX - Static variable in class org.fusesource.stompjms.StompJmsDestination
 
toString() - Method in class org.fusesource.stompjms.client.StompFrame
 
toString() - Method in class org.fusesource.stompjms.client.transport.BaseService.State
 
toString() - Method in class org.fusesource.stompjms.client.transport.TcpTransportServer
 
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
 
toString(AsciiBuffer) - Static method in class org.fusesource.stompjms.util.StompTranslator
 
trafficClass(int) - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
trafficClass(int) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
trafficClass(int) - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 
TRANSACTION - Static variable in interface org.fusesource.stompjms.client.Constants
 
transactionId - Variable in class org.fusesource.stompjms.message.StompJmsMessage
 
TRANSFORMATION - Static variable in interface org.fusesource.stompjms.client.Constants
 
TRANSFORMATION_ERROR - Static variable in interface org.fusesource.stompjms.client.Constants
 
transformDestination(Destination) - Static method in class org.fusesource.stompjms.message.StompJmsMessageTransformation
Creates a an available JMS message from another provider.
transformEnvironment(Hashtable) - Method in class org.fusesource.stompjms.jndi.WasStompJmsInitialContextFactory
Performs following transformation of properties: (java.naming.queue.xxx.yyy,value)=>(queue.xxx/yyy,value) (java.naming.topic.xxx.yyy,value)=>(topic.xxx/yyy,value) (java.naming.connectionFactoryNames,value)=>(connectionFactoryNames,value) (java.naming.provider.url,url1;url2)=>java.naming.provider.url,url1,url1)
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.
transport() - Method in class org.fusesource.stompjms.client.callback.Connection
 
Transport - Interface in org.fusesource.stompjms.client.transport
Represents an abstract connection.
TransportListener - Interface in org.fusesource.stompjms.client.transport
An asynchronous listener of commands
TransportServer - Interface in org.fusesource.stompjms.client.transport
A TransportServer asynchronously accepts Transport objects and then delivers those objects to a TransportAcceptListener.
TransportServerListener - Interface in org.fusesource.stompjms.client.transport
Implemented by object that need to get injected by
treeBindings - Variable in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
TRUE - Static variable in interface org.fusesource.stompjms.client.Constants
 
TYPE - Static variable in interface org.fusesource.stompjms.client.Constants
 
TypeConversionSupport - Class in org.fusesource.stompjms.util
 

U

unbind(Name) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
unbind(String) - Method in class org.fusesource.stompjms.jndi.ReadOnlyContext
 
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
 
unread(Buffer) - Method in class org.fusesource.stompjms.client.StompProtocolCodec
 
unread(Buffer) - Method in interface org.fusesource.stompjms.client.transport.ProtocolCodec
Pushes back a buffer as being unread.
UNSUBSCRIBE - Static variable in interface org.fusesource.stompjms.client.Constants
 
unsubscribe(StompJmsDestination, AsciiBuffer, boolean, boolean) - Method in class org.fusesource.stompjms.StompChannel
 
unsubscribe(String) - Method in class org.fusesource.stompjms.StompJmsQueueSession
 
unsubscribe(String) - Method in class org.fusesource.stompjms.StompJmsSession
 
useLocalHost(boolean) - Method in class org.fusesource.stompjms.client.blocking.ConnectionBuilder
 
useLocalHost(boolean) - Method in class org.fusesource.stompjms.client.callback.ConnectionBuilder
 
useLocalHost(boolean) - Method in class org.fusesource.stompjms.client.future.ConnectionBuilder
 
useLocalHost - Variable in class org.fusesource.stompjms.client.transport.TcpTransport
 
USERID - Static variable in interface org.fusesource.stompjms.client.Constants
 

V

V1_0 - Static variable in interface org.fusesource.stompjms.client.Constants
 
V1_1 - Static variable in interface org.fusesource.stompjms.client.Constants
 
value - Variable in class org.fusesource.stompjms.client.StompFrame.HeaderEntry
 
valueOf(String) - Static method in enum org.fusesource.stompjms.client.transport.ProtocolCodec.BufferState
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.client.transport.ProtocolCodec.BufferState
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.
WasStompJmsInitialContextFactory - Class in org.fusesource.stompjms.jndi
This implementation of InitialContextFactory should be used when StompJms is used as WebSphere Generic JMS Provider.
WasStompJmsInitialContextFactory() - Constructor for class org.fusesource.stompjms.jndi.WasStompJmsInitialContextFactory
 
write(DataOutput) - Method in class org.fusesource.stompjms.client.StompFrame
 
write(DataOutput, boolean) - Method in class org.fusesource.stompjms.client.StompFrame
 
write(Object) - Method in class org.fusesource.stompjms.client.StompProtocolCodec
 
write(Object) - Method in interface org.fusesource.stompjms.client.transport.ProtocolCodec
Non-blocking channel based encoding.
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.util.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.
writeChannel() - Method in class org.fusesource.stompjms.client.transport.SslTransport
 
writeChannel() - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
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.
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.

_

_serviceState - Variable in class org.fusesource.stompjms.client.transport.BaseService
 
_start(Runnable) - Method in class org.fusesource.stompjms.client.transport.BaseService
 
_start(Runnable) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 
_stop(Runnable) - Method in class org.fusesource.stompjms.client.transport.BaseService
 
_stop(Runnable) - Method in class org.fusesource.stompjms.client.transport.TcpTransport
 

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

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