|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
BytesMessage
object is used to send a message containing a stream of uninterpreted bytes.Connection
object is a client's active connection to its JMS provider.Connection
objects provide a special
facility for creating a ConnectionConsumer
(optional).ConnectionFactory
with an already configured and started BrokerContainer
ready for use in embedded mode.
ConnectionFactory
with an already configured and started BrokerContainer
ready for use in embedded mode and the brokerURL connection.
ConnectionMetaData
object provides information describing
the Connection
object.Destination
object encapsulates a provider-specific
address.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.MapMessage
object is used to send a set of name-value pairs.Message
interface is the root interface of all JMS
messages.MessageConsumer
object to receive messages from a destination.MessageProducer
object to send messages to a
destination.ObjectMessage
object is used to send a message that contains
a serializable object in the Java programming language ("Java object").Queue
object encapsulates a provider-specific queue name.QueueBrowser
object to look at messages on a
queue without removing them.QueueReceiver
object to receive messages that
have been delivered to a queue.QueueSender
object to send messages to a
queue.Session
object is a single-threaded context for producing and consuming messages.StreamMessage
object is used to send a stream of primitive
types in the Java programming language.TemporaryQueue
object is a unique Queue
object
created for the duration of a Connection
.TemporaryTopic
object is a unique Topic
object
created for the duration of a Connection
.TextMessage
object is used to send a message containing a
java.lang.String
.Topic
object encapsulates a provider-specific topic name.TopicPublisher
object to publish messages on
a topic.TopicSubscriber
object to receive messages
that have been published to a topic.ActiveMQXid
object holds the distributed
transaction id that is passed around in an ActiveMQ system.xid
MessageStore
using
native C Berkeley DBPersistenceAdapter
implementation using
Berkeley DB Java EditionTopicMessageStore
using
native C Berkeley DBBroker
and one or more
instances talking over some TransportChannel
Note that once a broker container has been stopped it should be discarded and a new service
instance created again.bufferCount
ByteBuffers that are
directly allocated being bufferSize
big.
PersistenceAdapter
designed to
to speed up access to recently added messages by using
a MessageCache .TransactionTemplate
and ExceptionTemplate
objects to provide automatic transactional or exception handling blocks.DestinationFilter
used for composite destinationsQueueBrowser
object to peek at the messages on the specified queue.
QueueBrowser
object to peek at the messages on the specified queue using a message
selector.
BytesMessage
object.
MessageConsumer
for the specified destination.
MessageConsumer
for the specified destination, using a message selector.
MessageConsumer
for the specified destination, using a message selector.
MessageContainer
Destination
MapMessage
object.
Message
object.
ObjectMessage
object.
ObjectMessage
object.
MessageProducer
to send messages to the specified destination.
Queue
name.
QueueSession
object.
QueueReceiver
object to receive messages from the specified queue.
QueueReceiver
object to receive messages from the specified queue using a message
selector.
QueueSender
object to send messages to the specified queue.
Session
object.
StreamMessage
object.
TemporaryQueue
object.
TemporaryTopic
object.
TextMessage
object.
TextMessage
object.
Topic
name.
TopicSession
object.
PERSISTENT
.
Broker
implementationComparator
which only works on objects
which are Comparable
ActiveMQDestination
and retrieved by destination - supporting both * and > style of wildcard
as well as composite destinations.DestinationMap
DiscoveryAgent
implementationsNetworkConnector
which uses discovery to find remote brokers
to connect toReliableTransportChannel
which uses a DiscoveryAgent
to discover remote broker
instances and dynamically connect to them.MessageContainer
which acts as an adapter between the MessageContainerManager
requirements and those of the persistent MessageStore
implementations.MessageContainer
which acts as an adapter between the MessageContainerManager
requirements and those of the persistent TopicMessageStore
implementations.SubscriptionContainerImpl
for durable topic
subscriptionsout
object.
Executor
objectsput
into this object.
put
into this object.
boolean
value with the specified name.
boolean
property with the
specified name.
byte
value with the specified name.
byte
property with the specified
name.
MessageProducer
.
Destination
objects available in this container
double
value with the specified name.
double
property with the specified
name.
ExceptionListener
object for this connection.
float
value with the specified name.
float
property with the specified
name.
Destination
objects active on startup.
int
value with the specified name.
int
property with the specified
name.
DeliveryMode
value specified for this message.
Destination
object for this message.
Destination
object to which a reply to this
message should be sent.
long
value with the specified name.
long
property with the specified
name.
Enumeration
of all the names in the MapMessage
object.
MessageListener
.
NetworkConnector
instances used to communicate with the network of Broker
instances
location
that
is in the journal.
NoLocal
attribute for this subscriber.
Enumeration
of all the property names.
Queue
associated with this queue receiver.
QueueSender
.
timeout
timeout ms to get a receipt
short
value with the specified name.
short
property with the specified
name.
String
value with the specified name.
String
property with the specified
name.
TopicPublisher
.
Topic
associated with this subscriber.
MessageStore
designed for
optimal use with Howl
as the transaction log and then checkpointing asynchronously
on a timeout with some other persistent storage.PersistenceAdapter
designed for
optimal use with Howl
as the transaction log and then checkpointing asynchronously
on a timeout with some other persistent storage.TransportChannel
which uses the
commons-httpclient libraryChannel
so that they can be dispatched
by the HTTP GET requests from the client.RedeliveryPolicy.getBackOffIncreaseRate()
each time).
MapMessage
object.
PersistenceAdapter
implementation using JDBC for
persistence storage.Destination
as well.MessageProducer
or MessageConsumer
as it passes in a
Session
parent statistic.
Destination
Queue
Topic
PersistenceAdapter
implementation for
JDBMPersistenceAdapter
designed for
use with a Journal
and then checkpointing asynchronously
on a timeout with some other long term persistent storage.next.
- JxtaTransportChannel - class org.codehaus.activemq.transport.jxta.JxtaTransportChannel.
- A JXTA implementation of a TransportChannel
- JxtaTransportChannel(WireFormat, URI) -
Constructor for class org.codehaus.activemq.transport.jxta.JxtaTransportChannel
- Connect to a remote Node - e.g.
- JxtaTransportChannel(WireFormat, URI, URI) -
Constructor for class org.codehaus.activemq.transport.jxta.JxtaTransportChannel
- Connect to a remote Node - e.g.
- JxtaTransportChannelFactory - class org.codehaus.activemq.transport.jxta.JxtaTransportChannelFactory.
- A JXTA implementation of a TransportChannelFactory
- JxtaTransportChannelFactory() -
Constructor for class org.codehaus.activemq.transport.jxta.JxtaTransportChannelFactory
-
- JxtaTransportServerChannel - class org.codehaus.activemq.transport.jxta.JxtaTransportServerChannel.
- Binds to a well known port and listens for Sockets ...
- JxtaTransportServerChannel(WireFormat, URI) -
Constructor for class org.codehaus.activemq.transport.jxta.JxtaTransportServerChannel
- Default Constructor
- JxtaTransportServerChannelFactory - class org.codehaus.activemq.transport.jxta.JxtaTransportServerChannelFactory.
- A JXTA implementation of a TransportServerChannelFactory
- JxtaTransportServerChannelFactory() -
Constructor for class org.codehaus.activemq.transport.jxta.JxtaTransportServerChannelFactory
-
- jj_input_stream -
Variable in class org.codehaus.activemq.selector.SelectorParser
-
- jj_nt -
Variable in class org.codehaus.activemq.selector.SelectorParser
-
- jjbitVec0 -
Static variable in class org.codehaus.activemq.selector.SelectorParserTokenManager
-
- jjbitVec2 -
Static variable in class org.codehaus.activemq.selector.SelectorParserTokenManager
-
- jjmatchedKind -
Variable in class org.codehaus.activemq.selector.SelectorParserTokenManager
-
- jjmatchedPos -
Variable in class org.codehaus.activemq.selector.SelectorParserTokenManager
-
- jjnewStateCnt -
Variable in class org.codehaus.activemq.selector.SelectorParserTokenManager
-
- jjnextStates -
Static variable in class org.codehaus.activemq.selector.SelectorParserTokenManager
-
- jjround -
Variable in class org.codehaus.activemq.selector.SelectorParserTokenManager
-
- jjstrLiteralImages -
Static variable in class org.codehaus.activemq.selector.SelectorParserTokenManager
-
- jjtoSkip -
Static variable in class org.codehaus.activemq.selector.SelectorParserTokenManager
-
- jjtoSpecial -
Static variable in class org.codehaus.activemq.selector.SelectorParserTokenManager
-
- jjtoToken -
Static variable in class org.codehaus.activemq.selector.SelectorParserTokenManager
-
MessageContainer
implementationsNameParser
MessageContainerManager
which
delegates to some other implementation which is useful for writing
Facade implementationsMessageContainer
Journal.put()
method call.len
bytes of data into an array of bytes from this input stream.
boolean
from the bytes message stream.
boolean
from the stream message.
byte
value from the stream message.
byte[]
object (the read buffer).
double
from the bytes message stream.
double
from the stream message.
float
from the bytes message stream.
float
from the stream message.
readOnlyMessage
denotes if the message is read only
String
from the stream message.
WireByteArrayInputStream
to use an new byte array
WireByteArrayInputStream
to use an new byte array
Service
represents some service of some kind with a simple start/stop lifecycle.BrokerContainerFactory
which uses an XML
deployment configuration file to load and configure a BrokerContainer
SubscriptionContainer
MessageProducer
's default
delivery mode, priority, and time to live.
boolean
value with the specified name into the Map.
boolean
property value with the specified name into
the message.
byte
value with the specified name into the Map.
byte
property value with the specified name into
the message.
double
value with the specified name into the Map.
double
property value with the specified name into
the message.
float
value with the specified name into the Map.
float
property value with the specified name into
the message.
int
value with the specified name into the Map.
int
property value with the specified name into
the message.
DeliveryMode
value for this message.
Destination
object for this message.
Destination
object to which a reply to this
message should be sent.
JournalEventListener
that will receive notifications from the Journal.
long
value with the specified name into the Map.
long
property value with the specified name into
the message.
location
is no longer
needed and can be reclaimed for reuse.
MessageListener
.
NetworkChannel
instances
short
value with the specified name into the Map.
short
property value with the specified name into
the message.
String
value with the specified name into the Map.
String
property value with the specified name into
the message.
XStreamWireFormat
or the
JabberWireFormat
MessageContainer
MessageStore
which uses aWireByteArrayInputStream
.
WireByteArrayInputStream
that uses buf
as its buffer array.
WireByteArrayInputStream
with a minmalist byte array
record
to the journal.
len
bytes from the specified byte array starting at offset off
to this byte
array output stream.
boolean
to the bytes message stream as a 1-byte value.
boolean
to the stream message.
byte
to the bytes message stream as a 1-byte value.
byte
to the stream message.
char
to the bytes message stream as a 2-byte value, high byte first.
char
to the stream message.
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.
double
to the stream message.
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.
float
to the stream message.
int
to the bytes message stream as four bytes, high byte first.
int
to the stream message.
long
to the bytes message stream as eight bytes, high byte first.
long
to the stream message.
short
to the bytes message stream as two bytes, high byte first.
short
to the stream message.
String
to the stream message.
WireFormat
implementation which uses the
XStreamWireFormat() -
Constructor for class org.codehaus.activemq.transport.xstream.XStreamWireFormat
DiscoveryAgent
using Zeroconf
via the jmDNS libraryTransportServerChannel
TransportServerChannelFactory
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |