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

A

AbstractConnector - Class in org.hornetq.spi.core.remoting

Abstract connector

AbstractConnector(Map<String, Object>) - Constructor for class org.hornetq.spi.core.remoting.AbstractConnector

AcceptorControl - Interface in org.hornetq.api.core.management

An AcceptorControl is used to manage Acceptors.

acknowledge() - Method in interface org.hornetq.api.core.client.ClientMessage

Acknowledge reception of this message.

addAddressSettings(String, String, String, long, boolean, int, long, int, int, long, double, long, long, boolean, String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

adds a new address setting for a specific address

addCloseListener(CloseListener) - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

add a CloseListener.

addClusterTopologyListener(ClusterTopologyListener) - Method in interface org.hornetq.api.core.client.ServerLocator

addFailoverListener(FailoverEventListener) - Method in interface org.hornetq.api.core.client.ClientSession

Adds a FailoverEventListener to the session which is notified if a failover event occurs on the session.

addFailoverListener(FailoverEventListener) - Method in interface org.hornetq.api.core.client.ClientSessionFactory

Adds a FailoverEventListener to the session which is notified if a failover event occurs on the session.

addFailureListener(SessionFailureListener) - Method in interface org.hornetq.api.core.client.ClientSession

Adds a FailureListener to the session which is notified if a failure occurs on the session.

addFailureListener(FailureListener) - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

add a failure listener.

addIncomingInterceptor(Interceptor) - Method in interface org.hornetq.api.core.client.ServerLocator

Adds an interceptor which will be executed after packets are received from the server.

addInterceptor(Interceptor) - Method in interface org.hornetq.api.core.client.ServerLocator

Deprecated. As of HornetQ 2.3.0.Final, replaced by ServerLocator.addIncomingInterceptor(Interceptor) and ServerLocator.addOutgoingInterceptor(Interceptor)

addMetaData(String, String) - Method in interface org.hornetq.api.core.client.ClientSession

Attach any metadata to the session.

addOutgoingInterceptor(Interceptor) - Method in interface org.hornetq.api.core.client.ServerLocator

Adds an interceptor which will be executed before packets are sent to the server.

addReadyListener(ReadyListener) - Method in interface org.hornetq.spi.core.remoting.Connection

AddressControl - Interface in org.hornetq.api.core.management

An AddressControl is used to manage an address.

AddressSettingsInfo - Class in org.hornetq.api.core.management

A AddressSettingsInfo

AddressSettingsInfo(String, long, int, int, int, long, double, long, String, String, boolean, long, boolean) - Constructor for class org.hornetq.api.core.management.AddressSettingsInfo

addSecuritySettings(String, String, String, String, String, String, String, String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

addUniqueMetaData(String, String) - Method in interface org.hornetq.api.core.client.ClientSession

Attach any metadata to the session.

B

beforeReconnect(HornetQException) - Method in interface org.hornetq.api.core.client.SessionFailureListener

Notifies that a connection has failed due to the specified exception.

bindingQuery(SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession

Queries information on a binding.

BridgeControl - Interface in org.hornetq.api.core.management

A BridgeControl is used to manage a Bridge.

broadcast(byte[]) - Method in interface org.hornetq.api.core.BroadcastEndpoint

Broadcasting data to the cluster.

BroadcastEndpoint - Interface in org.hornetq.api.core

BroadcastEndpint is used in BroadcastGroups and DiscoveryGroups for topology updates.

BroadcastEndpointFactory - Interface in org.hornetq.api.core

BroadcastEndpointFactoryConfiguration - Interface in org.hornetq.api.core

BroadcastGroupConfiguration - Class in org.hornetq.api.core

The basic configuration used to determine how the server will broadcast members This is analogous to DiscoveryGroupConfiguration

BroadcastGroupConfiguration(String, long, List<String>, BroadcastEndpointFactoryConfiguration) - Constructor for class org.hornetq.api.core.BroadcastGroupConfiguration

BroadcastGroupControl - Interface in org.hornetq.api.core.management

A BroadcastGroupControl is used to manage a broadcast group.

BufferDecoder - Interface in org.hornetq.spi.core.remoting

A BufferDecoder

BufferHandler - Interface in org.hornetq.spi.core.remoting

A BufferHandler that will handle buffers received by an acceptor.

bufferReceived(Object, HornetQBuffer) - Method in interface org.hornetq.spi.core.remoting.BufferHandler

called by the remoting connection when a buffer is received.

BYTES_TYPE - Static variable in interface org.hornetq.api.core.Message

C

changeMessagePriority(long, int) - Method in interface org.hornetq.api.core.management.QueueControl

Changes the message's priority corresponding to the specified message ID to the specified priority.

changeMessagesPriority(String, int) - Method in interface org.hornetq.api.core.management.QueueControl

Changes the priority for all the message corresponding to the specified filter to the specified priority.

checkCompletion() - Method in interface org.hornetq.api.core.client.ClientMessage

This can be optionally used to verify if the entire message has been received.

checkDataReceived() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

returns true if any data has been received since the last time this method was called.

checkFlushBatchBuffer() - Method in interface org.hornetq.spi.core.remoting.Connection

Called periodically to flush any data in the batch buffer

cleanup() - Method in interface org.hornetq.api.core.client.ClientSessionFactory

Opposed to close, will call cleanup only on every created session and children objects.

ClientConsumer - Interface in org.hornetq.api.core.client

A ClientConsumer receives messages from HornetQ queues.

ClientMessage - Interface in org.hornetq.api.core.client

A ClientMessage represents a message sent and/or received by HornetQ.

ClientProducer - Interface in org.hornetq.api.core.client

A ClientProducer is used to send messages to a specific address.

ClientRequestor - Class in org.hornetq.api.core.client

The ClientRequestor class helps making requests.

ClientRequestor(ClientSession, SimpleString) - Constructor for class org.hornetq.api.core.client.ClientRequestor

Constructor for the ClientRequestor.

ClientRequestor(ClientSession, String) - Constructor for class org.hornetq.api.core.client.ClientRequestor

ClientSession - Interface in org.hornetq.api.core.client

A ClientSession is a single-thread object required for producing and consuming messages.

ClientSession.BindingQuery - Interface in org.hornetq.api.core.client

Information returned by a binding query

ClientSession.QueueQuery - Interface in org.hornetq.api.core.client

Information returned by a queue query

ClientSessionFactory - Interface in org.hornetq.api.core.client

A ClientSessionFactory is the entry point to create and configure HornetQ resources to produce and consume messages.

close(boolean) - Method in interface org.hornetq.api.core.BroadcastEndpoint

Close the endpoint.

close() - Method in interface org.hornetq.api.core.client.ClientConsumer

Closes the consumer.

close() - Method in interface org.hornetq.api.core.client.ClientProducer

Closes the ClientProducer.

close() - Method in class org.hornetq.api.core.client.ClientRequestor

Closes the ClientRequestor and its session.

close() - Method in interface org.hornetq.api.core.client.ClientSession

Closes the session.

close() - Method in interface org.hornetq.api.core.client.ClientSessionFactory

Closes this factory and any session created by it.

close() - Method in interface org.hornetq.api.core.client.ServerLocator

Closes this factory and release all its resources

close() - Method in interface org.hornetq.spi.core.remoting.Connection

Closes the connection.

close() - Method in interface org.hornetq.spi.core.remoting.Connector

closes the connector

closeConnectionsForAddress(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

Closes all the connections of clients connected to this server which matches the specified IP address.

ClusterConnectionControl - Interface in org.hornetq.api.core.management

A ClusterConnectionControl is used to manage a cluster connection.

ClusterTopologyListener - Interface in org.hornetq.api.core.client

A cluster topology listener.

commit() - Method in interface org.hornetq.api.core.client.ClientSession

Commits the current transaction.

commitPreparedTransaction(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

Heuristically commits a prepared transaction.

configuration - Variable in class org.hornetq.spi.core.remoting.AbstractConnector

connection - Variable in class org.hornetq.spi.core.protocol.ConnectionEntry

Connection - Interface in org.hornetq.spi.core.remoting

The connection used by a channel to write data to.

connectionCreated(HornetQComponent, Connection, ProtocolType) - Method in interface org.hornetq.spi.core.remoting.ConnectionLifeCycleListener

This method is used both by client connector creation and server connection creation through acceptors.

connectionDestroyed(Object) - Method in interface org.hornetq.spi.core.remoting.ConnectionLifeCycleListener

Called when a connection is destroyed.

ConnectionEntry - Class in org.hornetq.spi.core.protocol

A ConnectionEntry

ConnectionEntry(RemotingConnection, Executor, long, long) - Constructor for class org.hornetq.spi.core.protocol.ConnectionEntry

connectionException(Object, HornetQException) - Method in interface org.hornetq.spi.core.remoting.ConnectionLifeCycleListener

Called when an error occurs on the connection.

connectionExecutor - Variable in class org.hornetq.spi.core.protocol.ConnectionEntry

ConnectionLifeCycleListener - Interface in org.hornetq.spi.core.remoting

A ConnectionLifeCycleListener is called by the remoting implementation to notify of connection events.

ConnectionLoadBalancingPolicy - Interface in org.hornetq.api.core.client.loadbalance

A ConnectionLoadBalancingPolicy defines a policy to load balance between connections.

connectionReadyForWrites(Object, boolean) - Method in interface org.hornetq.spi.core.remoting.ConnectionLifeCycleListener

Connector - Interface in org.hornetq.spi.core.remoting

A Connector is used by the client for creating and controlling a connection.

ConnectorFactory - Interface in org.hornetq.spi.core.remoting

A ConnectorFactory is used by the client for creating connectors.

containsProperty(SimpleString) - Method in interface org.hornetq.api.core.Message

Returns true if this message contains a property with the given key, false else.

containsProperty(String) - Method in interface org.hornetq.api.core.Message

CORE_ACCEPTOR - Static variable in class org.hornetq.api.core.management.ResourceNames

CORE_ADDRESS - Static variable in class org.hornetq.api.core.management.ResourceNames

CORE_BRIDGE - Static variable in class org.hornetq.api.core.management.ResourceNames

CORE_BROADCAST_GROUP - Static variable in class org.hornetq.api.core.management.ResourceNames

CORE_CLUSTER_CONNECTION - Static variable in class org.hornetq.api.core.management.ResourceNames

CORE_DISCOVERY_GROUP - Static variable in class org.hornetq.api.core.management.ResourceNames

CORE_DIVERT - Static variable in class org.hornetq.api.core.management.ResourceNames

CORE_QUEUE - Static variable in class org.hornetq.api.core.management.ResourceNames

CORE_SERVER - Static variable in class org.hornetq.api.core.management.ResourceNames

countMessages(String) - Method in interface org.hornetq.api.core.management.QueueControl

Counts the number of messages in this queue matching the specified filter.

create(String) - Static method in class org.hornetq.api.core.management.ObjectNameBuilder

createBridge(String, String, String, String, String, long, double, int, boolean, int, long, String, boolean, boolean, String, String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

createBroadcastEndpoint() - Method in interface org.hornetq.api.core.BroadcastEndpointFactory

createBroadcastEndpointFactory() - Method in interface org.hornetq.api.core.BroadcastEndpointFactoryConfiguration

createBroadcastEndpointFactory() - Method in class org.hornetq.api.core.JGroupsBroadcastGroupConfiguration

createBroadcastEndpointFactory() - Method in class org.hornetq.api.core.UDPBroadcastGroupConfiguration

createBuffer(int) - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

creates a new HornetQBuffer of the specified size.

createBuffer(int) - Method in interface org.hornetq.spi.core.remoting.Connection

Create a new HornetQBuffer of the given size.

createConnection() - Method in interface org.hornetq.spi.core.remoting.Connector

Create and return a connection from this connector.

createConnector(Map<String, Object>, BufferHandler, ConnectionLifeCycleListener, Executor, Executor, ScheduledExecutorService) - Method in interface org.hornetq.spi.core.remoting.ConnectorFactory

creates a new instance of a connector.

createConsumer(SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a ClientConsumer to consume message from the queue with the given name.

createConsumer(String) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a ClientConsumer to consume messages from the queue with the given name.

createConsumer(SimpleString, SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.

createConsumer(String, String) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.

createConsumer(SimpleString, boolean) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a ClientConsumer to consume or browse messages from the queue with the given name.

createConsumer(String, boolean) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a ClientConsumer to consume or browse messages from the queue with the given name.

createConsumer(String, String, boolean) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.

createConsumer(SimpleString, SimpleString, boolean) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.

createConsumer(SimpleString, SimpleString, int, int, boolean) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.

createConsumer(String, String, int, int, boolean) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.

createDivert(String, String, String, String, boolean, String, String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

createMessage(boolean) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a ClientMessage.

createMessage(byte, boolean) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a ClientMessage.

createMessage(byte, boolean, long, long, byte) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a ClientMessage.

createProducer() - Method in interface org.hornetq.api.core.client.ClientSession

Creates a producer with no default address.

createProducer(SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a producer which sends messages to the given address

createProducer(String) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a producer which sends messages to the given address

createProducer(SimpleString, int) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a producer which sends messages to the given address

createQueue(SimpleString, SimpleString, boolean) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a non-temporary queue.

createQueue(String, String, boolean) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a non-temporary queue.

createQueue(String, String) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a non-temporary queue non-durable queue.

createQueue(SimpleString, SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a non-temporary queue non-durable queue.

createQueue(SimpleString, SimpleString, SimpleString, boolean) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a non-temporary queue.

createQueue(String, String, String, boolean) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a non-temporaryqueue.

createQueue(String, String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

Create a durable queue.

createQueue(String, String, String, boolean) - Method in interface org.hornetq.api.core.management.HornetQServerControl

Create a queue.

createQueue(String, String, boolean) - Method in interface org.hornetq.api.core.management.HornetQServerControl

Create a queue.

createServerLocator(boolean, TransportConfiguration...) - Static method in class org.hornetq.api.core.client.HornetQClient

Create a ServerLocator which creates session factories using a static list of transportConfigurations, the ServerLocator is not updated automatically as the cluster topology changes, and no HA backup information is propagated to the client

createServerLocator(boolean, DiscoveryGroupConfiguration) - Static method in class org.hornetq.api.core.client.HornetQClient

Create a ServerLocator which creates session factories from a set of live servers, no HA backup information is propagated to the client The UDP address and port are used to listen for live servers in the cluster

createServerLocatorWithHA(TransportConfiguration...) - Static method in class org.hornetq.api.core.client.HornetQClient

Create a ServerLocator which will receive cluster topology updates from the cluster as servers leave or join and new backups are appointed or removed.

createServerLocatorWithHA(DiscoveryGroupConfiguration) - Static method in class org.hornetq.api.core.client.HornetQClient

Create a ServerLocator which will receive cluster topology updates from the cluster as servers leave or join and new backups are appointed or removed.

createServerLocatorWithoutHA(TransportConfiguration...) - Static method in class org.hornetq.api.core.client.HornetQClient

Create a ServerLocator which creates session factories using a static list of transportConfigurations, the ServerLocator is not updated automatically as the cluster topology changes, and no HA backup information is propagated to the client

createServerLocatorWithoutHA(DiscoveryGroupConfiguration) - Static method in class org.hornetq.api.core.client.HornetQClient

Create a ServerLocator which creates session factories from a set of live servers, no HA backup information is propagated to the client

createSession() - Method in interface org.hornetq.api.core.client.ClientSessionFactory

Creates a non-transacted session.

createSession(boolean, boolean) - Method in interface org.hornetq.api.core.client.ClientSessionFactory

Creates a session.

createSession(boolean, boolean, int) - Method in interface org.hornetq.api.core.client.ClientSessionFactory

Creates a session.

createSession(boolean, boolean, boolean) - Method in interface org.hornetq.api.core.client.ClientSessionFactory

Creates a session.

createSession(boolean, boolean, boolean, boolean) - Method in interface org.hornetq.api.core.client.ClientSessionFactory

Creates a session.

createSession(String, String, boolean, boolean, boolean, boolean, int) - Method in interface org.hornetq.api.core.client.ClientSessionFactory

Creates an authenticated session.

createSessionFactory() - Method in interface org.hornetq.api.core.client.ServerLocator

Creates a ClientSessionFactory using whatever load balancing policy is in force

createSessionFactory(String) - Method in interface org.hornetq.api.core.client.ServerLocator

Creates a ClientSessionFactory to a specific server.

createSessionFactory(TransportConfiguration) - Method in interface org.hornetq.api.core.client.ServerLocator

Creates a ClientSessionFactory to a specific server.

createSessionFactory(TransportConfiguration, int, boolean) - Method in interface org.hornetq.api.core.client.ServerLocator

Creates a ClientSessionFactory to a specific server.

createTemporaryQueue(SimpleString, SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a temporary queue.

createTemporaryQueue(String, String) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a temporary queue.

createTemporaryQueue(SimpleString, SimpleString, SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a temporary queue with a filter.

createTemporaryQueue(String, String, String) - Method in interface org.hornetq.api.core.client.ClientSession

Creates a temporary queue with a filter.

createTransactedSession() - Method in interface org.hornetq.api.core.client.ClientSessionFactory

Creates a transacted session.

createXASession() - Method in interface org.hornetq.api.core.client.ClientSessionFactory

Creates a session with XA transaction semantics.

D

DayCounterInfo - Class in org.hornetq.api.core.management

Helper class to create Java Objects from the JSON serialization returned by QueueControl.listMessageCounterHistory().

DayCounterInfo(String, int[]) - Constructor for class org.hornetq.api.core.management.DayCounterInfo

decode(HornetQBuffer) - Method in class org.hornetq.api.core.TransportConfiguration

Decodes this TransportConfiguration from a buffer.

DEFAULT - Static variable in class org.hornetq.api.core.management.ObjectNameBuilder

Default JMX domain for HornetQ resources.

DEFAULT_ACK_BATCH_SIZE - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_AUTO_GROUP - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_BLOCK_ON_ACKNOWLEDGE - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_BLOCK_ON_DURABLE_SEND - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_BLOCK_ON_NON_DURABLE_SEND - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_CACHE_LARGE_MESSAGE_CLIENT - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_CALL_FAILOVER_TIMEOUT - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_CALL_TIMEOUT - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_CLIENT_FAILURE_CHECK_PERIOD - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_COMPRESS_LARGE_MESSAGES - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_CONFIRMATION_WINDOW_SIZE - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_CONNECTION_LOAD_BALANCING_POLICY_CLASS_NAME - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_CONNECTION_TTL - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_CONSUMER_MAX_RATE - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_CONSUMER_WINDOW_SIZE - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_DISCOVERY_INITIAL_WAIT_TIMEOUT - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_DISCOVERY_PORT - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_DISCOVERY_REFRESH_TIMEOUT - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_FAILOVER_ON_INITIAL_CONNECTION - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_HA - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_INITIAL_MESSAGE_PACKET_SIZE - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_IS_HA - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_MAX_RETRY_INTERVAL - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_MIN_LARGE_MESSAGE_SIZE - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_PRE_ACKNOWLEDGE - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_PRODUCER_MAX_RATE - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_PRODUCER_WINDOW_SIZE - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_RECONNECT_ATTEMPTS - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_RETRY_INTERVAL - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_RETRY_INTERVAL_MULTIPLIER - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_THREAD_POOL_MAX_SIZE - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_TYPE - Static variable in interface org.hornetq.api.core.Message

DEFAULT_USE_GLOBAL_POOLS - Static variable in class org.hornetq.api.core.client.HornetQClient

DEFAULT_XA - Static variable in class org.hornetq.api.core.client.HornetQClient

deleteQueue(SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession

Deletes the queue.

deleteQueue(String) - Method in interface org.hornetq.api.core.client.ClientSession

Deletes the queue.

deployQueue(String, String, String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

Deploy a durable queue.

deployQueue(String, String, String, boolean) - Method in interface org.hornetq.api.core.management.HornetQServerControl

Deploy a queue.

destroy() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

destroys this connection.

destroyBridge(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

destroyDivert(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

destroyQueue(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

Destroys the queue corresponding to the specified name.

disableFinalizeCheck() - Method in interface org.hornetq.api.core.client.ServerLocator

This method will disable any checks when a GarbageCollection happens leaving connections open.

disableMessageCounters() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Disables message counters for this server.

disconnect(boolean) - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

Disconnect the connection, closing all channels

DiscoveryGroupConfiguration - Class in org.hornetq.api.core

This file represents how we are using Discovery.

DiscoveryGroupConfiguration(String, long, long, BroadcastEndpointFactoryConfiguration) - Constructor for class org.hornetq.api.core.DiscoveryGroupConfiguration

DiscoveryGroupConfiguration(long, long, BroadcastEndpointFactoryConfiguration) - Constructor for class org.hornetq.api.core.DiscoveryGroupConfiguration

DiscoveryGroupConfigurationCompatibilityHelper - Interface in org.hornetq.api.core

This interface is needed for making a DiscoveryGroupConfiguration backward compatible with version 2.2 clients.

DivertControl - Interface in org.hornetq.api.core.management

A DivertControl is used to manage a divert.

DURABLE - Static variable in class org.hornetq.api.core.FilterConstants

Value for the Durable header when the message is durable.

E

enableMessageCounters() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Enables message counters for this server.

encode(HornetQBuffer) - Method in class org.hornetq.api.core.TransportConfiguration

Encodes this TransportConfiguration into a buffer.

equals(Object) - Method in class org.hornetq.api.core.BroadcastGroupConfiguration

equals(Object) - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration

equals(Object) - Method in class org.hornetq.api.core.TransportConfiguration

equals(Object) - Method in class org.hornetq.api.core.UDPBroadcastGroupConfiguration

expireMessage(long) - Method in interface org.hornetq.api.core.management.QueueControl

Expires the message corresponding to the specified message ID.

expireMessages(String) - Method in interface org.hornetq.api.core.management.QueueControl

Expires all the message corresponding to the specified filter.

F

fail(HornetQException) - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

called when the underlying connection fails.

failoverEvent(FailoverEventType) - Method in interface org.hornetq.api.core.client.FailoverEventListener

Notifies that a connection state has changed according the specified event type.

FailoverEventListener - Interface in org.hornetq.api.core.client

A FailoverEvent notifies the client the state if the connection changes occurred on the session.

FailoverEventType - Enum in org.hornetq.api.core.client

FilterConstants - Class in org.hornetq.api.core

Constants representing pre-defined message attributes that can be referenced in HornetQ core filter expressions.

FirstElementConnectionLoadBalancingPolicy - Class in org.hornetq.api.core.client.loadbalance

A FirstElementConnectionLoadBalancingPolicy.select(int) always returns 0.

FirstElementConnectionLoadBalancingPolicy() - Constructor for class org.hornetq.api.core.client.loadbalance.FirstElementConnectionLoadBalancingPolicy

flush() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

flush all outstanding data from the connection.

forceFailover() - Method in interface org.hornetq.api.core.management.HornetQServerControl

from(String) - Static method in class org.hornetq.api.core.management.AddressSettingsInfo

from(String) - Static method in class org.hornetq.api.core.management.RoleInfo

Returns an array of RoleInfo corresponding to the JSON serialization returned by AddressControl.getRolesAsJSON().

fromCommaSeparatedArrayOfCommaSeparatedKeyValues(String) - Static method in class org.hornetq.api.core.management.ManagementHelper

Used by HornetQ management service.

fromCommaSeparatedKeyValues(String) - Static method in class org.hornetq.api.core.management.ManagementHelper

Used by HornetQ management service.

fromJSON(String) - Static method in class org.hornetq.api.core.management.DayCounterInfo

Returns an array of RoleInfo corresponding to the JSON serialization returned by QueueControl.listMessageCounterHistory().

G

getAcceptorObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder

Returns the ObjectName used by AcceptorControl.

getAckBatchSize() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the acknowledgments batch size.

getAddress() - Method in interface org.hornetq.api.core.client.ClientProducer

Returns the address where messages will be sent.

getAddress() - Method in interface org.hornetq.api.core.client.ClientSession.QueueQuery

Returns the address that the queue is bound to.

getAddress() - Method in interface org.hornetq.api.core.management.AddressControl

Returns the managed address.

getAddress() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl

Returns the address used by this cluster connection.

getAddress() - Method in interface org.hornetq.api.core.management.DivertControl

Returns the origin address used by this divert.

getAddress() - Method in interface org.hornetq.api.core.management.QueueControl

Returns the address this queue is bound to.

getAddress() - Method in interface org.hornetq.api.core.Message

Returns the address this message is sent to.

getAddressFullMessagePolicy() - Method in class org.hornetq.api.core.management.AddressSettingsInfo

getAddressNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the addresses created on this server.

getAddressObjectName(SimpleString) - Method in class org.hornetq.api.core.management.ObjectNameBuilder

Returns the ObjectName used by AddressControl.

getAddressSettingsAsJSON(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

returns the address settings as a JSON string

getAllowableProperties() - Method in interface org.hornetq.spi.core.remoting.ConnectorFactory

Returns the allowable properties for this connector.

getBackup() - Method in interface org.hornetq.api.core.client.TopologyMember

Returns the TransportConfiguration relative to the backup server if any.

getBackupGroupName() - Method in interface org.hornetq.api.core.client.TopologyMember

Returns the backup-group-name of the live server and backup servers associated with Topology entry.

getBindingNames() - Method in interface org.hornetq.api.core.management.AddressControl

Returns the names of all bindings (both queues and diverts) bound to this address

getBindingsDirectory() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the file system directory used to store bindings.

getBodyBuffer() - Method in interface org.hornetq.api.core.Message

Returns the message body as a HornetQBuffer

getBodyBufferCopy() - Method in interface org.hornetq.api.core.Message

Returns a copy of the message body as a HornetQBuffer.

getBodySize() - Method in interface org.hornetq.api.core.client.ClientMessage

Return the size (in bytes) of this message's body

getBooleanProperty(SimpleString) - Method in interface org.hornetq.api.core.Message

Returns the property corresponding to the specified key as a Boolean.

getBooleanProperty(String) - Method in interface org.hornetq.api.core.Message

getBridgeNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl

getBridgeObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder

Returns the ObjectName used by BridgeControl.

getBroadcastEndpointFactoryConfiguration() - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration

getBroadcastGroupObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder

Returns the ObjectName used by BroadcastGroupControl.

getBroadcastPeriod() - Method in class org.hornetq.api.core.BroadcastGroupConfiguration

getBroadcastPeriod() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl

Returns the period used by this broadcast group.

getByteProperty(SimpleString) - Method in interface org.hornetq.api.core.Message

Returns the property corresponding to the specified key as a Byte.

getByteProperty(String) - Method in interface org.hornetq.api.core.Message

getBytesProperty(SimpleString) - Method in interface org.hornetq.api.core.Message

Returns the property corresponding to the specified key as a byte[].

getBytesProperty(String) - Method in interface org.hornetq.api.core.Message

getCallFailoverTimeout() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the blocking calls failover timeout when the client is awaiting failover, this is over and above the normal call timeout.

getCallTimeout() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the blocking calls timeout.

getClientFailureCheckPeriod() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the period used to check if a client has failed to receive pings from the server.

getClusterConnectionObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder

Returns the ObjectName used by ClusterConnectionControl.

getConfirmationWindowSize() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the size for the confirmation window of clients using this factory.

getConnection() - Method in interface org.hornetq.api.core.client.ClientSessionFactory

Returns the code connection used by this session factory.

getConnectionCount() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the number of connections connected to this server.

getConnectionFactoryObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder

Returns the ObjectName used by ConnectionFactoryControl.

getConnectionLoadBalancingPolicyClassName() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the class name of the connection load balancing policy.

getConnectionTTL() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the connection time-to-live.

getConnectionTTLOverride() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the connection time to live.

getConnectorConfig() - Method in interface org.hornetq.spi.core.remoting.Connection

Generates a TransportConfiguration to be used to connect to the same target this is connected to.

getConnectorInfos() - Method in class org.hornetq.api.core.BroadcastGroupConfiguration

getConnectorPairs() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl

Returns the pairs of live-backup connectors that are broadcasted by this broadcast group.

getConnectorPairsAsJSON() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl

Returns the pairs of live-backup connectors that are broadcasted by this broadcast group using JSON serialization.

getConnectors() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the connectors configured for this server.

getConnectorsAsJSON() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the connectors configured for this server using JSON serialization.

getConsumerCount() - Method in interface org.hornetq.api.core.client.ClientSession.QueueQuery

Returns the number of consumers attached to the queue.

getConsumerCount() - Method in interface org.hornetq.api.core.management.QueueControl

Returns the number of consumers consuming messages from this queue.

getConsumerMaxRate() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the maximum rate of message consumption for consumers created through this factory.

getConsumerWindowSize() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the window size for flow control of the consumers created through this factory.

getCounters() - Method in class org.hornetq.api.core.management.DayCounterInfo

Returns a 24-length array corresponding to the number of messages added to the queue for the given hour of the day.

getCreationTime() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

Returns the creation time of the RemotingConnection.

getDate() - Method in class org.hornetq.api.core.management.DayCounterInfo

Returns the date of the counter.

getDeadLetterAddress() - Method in class org.hornetq.api.core.management.AddressSettingsInfo

getDeadLetterAddress() - Method in interface org.hornetq.api.core.management.QueueControl

Returns the dead-letter address associated to this queue.

getDefaultBindingsDirectory() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultBridgeReconnectAttempts() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultBroadcastPeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultBroadcastRefreshTimeout() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultClientFailureCheckPeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultClusterConnectionTtl() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultClusterFailureCheckPeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultClusterMaxHops() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultClusterMaxRetryInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultClusterNotificationAttempts() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultClusterNotificationInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultClusterPassword() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultClusterReconnectAttempts() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultClusterRetryInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultClusterRetryIntervalMultiplier() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultClusterUser() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultConnectionTtl() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultConnectionTtlOverride() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultFailbackDelay() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultFileDeployerScanPeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultHornetQPrincipal() - Method in interface org.hornetq.spi.core.remoting.Connection

getDefaultIdCacheSize() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultJmxDomain() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultJournalBufferSizeAio() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultJournalBufferSizeNio() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultJournalBufferTimeoutAio() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultJournalBufferTimeoutNio() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultJournalCompactMinFiles() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultJournalCompactPercentage() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultJournalDir() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultJournalFileSize() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultJournalMaxIoAio() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultJournalMaxIoNio() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultJournalMinFiles() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultJournalPerfBlastPages() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultLargeMessagesDir() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultManagementAddress() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultManagementNotificationAddress() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultMaxConcurrentPageIo() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultMaxRetryInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultMemoryMeasureInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultMemoryWarningThreshold() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultMessageCounterMaxDayHistory() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultMessageCounterSamplePeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultMessageExpiryScanPeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultMessageExpiryThreadPriority() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultPagingDir() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultRetryIntervalMultiplier() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultScheduledThreadPoolMaxSize() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultSecurityInvalidationInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultServerDumpInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultThreadPoolMaxSize() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultTransactionTimeout() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDefaultTransactionTimeoutScanPeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getDeliveringCount() - Method in interface org.hornetq.api.core.management.QueueControl

Returns the number of messages that this queue is currently delivering to its consumers.

getDeliveryCount() - Method in interface org.hornetq.api.core.client.ClientMessage

Returns the number of times this message was delivered.

getDiscoveryGroupConfiguration() - Method in interface org.hornetq.api.core.client.ServerLocator

The discovery group configuration

getDiscoveryGroupName() - Method in interface org.hornetq.api.core.management.BridgeControl

Returns the name of the discovery group used by this bridge.

getDiscoveryGroupName() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl

Returns the name of the discovery group used by this cluster connection.

getDiscoveryGroupObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder

Returns the ObjectName used by DiscoveryGroupControl.

getDiscoveryInitialWaitTimeout() - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration

getDivertNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl

getDivertObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder

Returns the ObjectName used by DivertControl.

getDoubleProperty(SimpleString) - Method in interface org.hornetq.api.core.Message

Returns the property corresponding to the specified key as a Double.

getDoubleProperty(String) - Method in interface org.hornetq.api.core.Message

getEncodeSize() - Method in interface org.hornetq.api.core.Message

Returns the size of the encoded message.

getEndpointFactoryConfiguration() - Method in class org.hornetq.api.core.BroadcastGroupConfiguration

getExpiration() - Method in interface org.hornetq.api.core.Message

Returns the expiration time of this message.

getExpiryAddress() - Method in class org.hornetq.api.core.management.AddressSettingsInfo

getExpiryAddress() - Method in interface org.hornetq.api.core.management.QueueControl

Returns the expiry address associated to this queue.

getFactoryClassName() - Method in interface org.hornetq.api.core.management.AcceptorControl

Returns the class name of the AcceptorFactory implementation used by this acceptor.

getFactoryClassName() - Method in class org.hornetq.api.core.TransportConfiguration

Returns the class name of ConnectorFactory being used by this TransportConfiguration

getFailureListeners() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

return all the failure listeners

getFilter() - Method in interface org.hornetq.api.core.management.DivertControl

Returns the filter used by this divert.

getFilter() - Method in interface org.hornetq.api.core.management.QueueControl

Returns the filter associated to this queue.

getFilterString() - Method in interface org.hornetq.api.core.client.ClientSession.QueueQuery

Returns the queue's filter string (or null if the queue has no filter).

getFilterString() - Method in interface org.hornetq.api.core.management.BridgeControl

Returns the filter string associated to this bridge.

getFloatProperty(SimpleString) - Method in interface org.hornetq.api.core.Message

Returns the property corresponding to the specified key as a Float.

getFloatProperty(String) - Method in interface org.hornetq.api.core.Message

getForwardingAddress() - Method in interface org.hornetq.api.core.management.BridgeControl

Returns the address this bridge will forward messages to.

getForwardingAddress() - Method in interface org.hornetq.api.core.management.DivertControl

Returns the forwarding address used by this divert.

getGroupAddress() - Method in interface org.hornetq.api.core.DiscoveryGroupConfigurationCompatibilityHelper

getGroupAddress() - Method in class org.hornetq.api.core.JGroupsBroadcastGroupConfiguration

getGroupAddress() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl

Returns the address this broadcast group is broadcasting to.

getGroupAddress() - Method in class org.hornetq.api.core.UDPBroadcastGroupConfiguration

getGroupID() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the group ID that will be eventually set on each message for the property Message.HDR_GROUP_ID.

getGroupPort() - Method in interface org.hornetq.api.core.DiscoveryGroupConfigurationCompatibilityHelper

getGroupPort() - Method in class org.hornetq.api.core.JGroupsBroadcastGroupConfiguration

getGroupPort() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl

Returns the port this broadcast group is broadcasting to.

getGroupPort() - Method in class org.hornetq.api.core.UDPBroadcastGroupConfiguration

getHornetQServerObjectName() - Method in class org.hornetq.api.core.management.ObjectNameBuilder

Returns the ObjectName used by the single HornetQServerControl.

getID() - Method in interface org.hornetq.api.core.management.QueueControl

Returns this queue ID.

getID() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

Returns the unique id of the RemotingConnection.

getID() - Method in interface org.hornetq.spi.core.remoting.Connection

returns the unique id of this wire.

getIDCacheSize() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the size of the cache for pre-creating message IDs.

getIncomingInterceptorClassNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the list of interceptors used by this server for incoming messages.

getInitialConnectAttempts() - Method in interface org.hornetq.api.core.client.ServerLocator

getInitialMessagePacketSize() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the initial size of messages created through this factory.

getInterceptorClassNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Deprecated. As of HornetQ 2.3.0.Final, replaced by HornetQServerControl.getIncomingInterceptorClassNames() and HornetQServerControl.getOutgoingInterceptorClassNames()

getIntProperty(SimpleString) - Method in interface org.hornetq.api.core.Message

Returns the property corresponding to the specified key as an Integer.

getIntProperty(String) - Method in interface org.hornetq.api.core.Message

getJMSQueueObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder

Returns the ObjectName used by JMSQueueControl.

getJMSServerObjectName() - Method in class org.hornetq.api.core.management.ObjectNameBuilder

Returns the ObjectName used by JMSServerControl.

getJMSTopicObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder

Returns the ObjectName used by TopicControl.

getJournalBufferSize() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the size of the internal buffer on the journal.

getJournalBufferTimeout() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the timeout (in nanoseconds) used to flush internal buffers on the journal.

getJournalCompactMinFiles() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the minimal number of journal files before compacting.

getJournalCompactPercentage() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Return the percentage of live data before compacting the journal.

getJournalDirectory() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the file system directory used to store journal log.

getJournalFileSize() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the size (in bytes) of each journal files.

getJournalMaxIO() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the maximum number of write requests that can be in the AIO queue at any given time.

getJournalMinFiles() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the number of journal files to pre-create.

getJournalType() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the type of journal used by this server (either NIO or ASYNCIO).

getLargeMessagesDirectory() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the file system directory used to store large messages.

getLastException() - Method in interface org.hornetq.api.core.client.ClientConsumer

Returns the last exception thrown by a call to this consumer's MessageHandler.

getLive() - Method in interface org.hornetq.api.core.client.TopologyMember

getLocalBindAddress() - Method in interface org.hornetq.api.core.DiscoveryGroupConfigurationCompatibilityHelper

getLocalBindAddress() - Method in class org.hornetq.api.core.JGroupsBroadcastGroupConfiguration

getLocalBindAddress() - Method in class org.hornetq.api.core.UDPBroadcastGroupConfiguration

getLocalBindPort() - Method in interface org.hornetq.api.core.DiscoveryGroupConfigurationCompatibilityHelper

getLocalBindPort() - Method in class org.hornetq.api.core.JGroupsBroadcastGroupConfiguration

getLocalBindPort() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl

Returns the local port this broadcast group is bound to.

getLocalBindPort() - Method in class org.hornetq.api.core.UDPBroadcastGroupConfiguration

getLongProperty(SimpleString) - Method in interface org.hornetq.api.core.Message

Returns the property corresponding to the specified key as a Long.

getLongProperty(String) - Method in interface org.hornetq.api.core.Message

getManagementAddress() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the management address of this server.

getManagementNotificationAddress() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the management notification address of this server.

getMaxDeliveryAttempts() - Method in class org.hornetq.api.core.management.AddressSettingsInfo

getMaxHops() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl

Returns the maximum number of hops used by this cluster connection.

getMaxRate() - Method in interface org.hornetq.api.core.client.ClientProducer

Returns the maximum rate at which a ClientProducer can send messages per second.

getMaxRedeliveryDelay() - Method in class org.hornetq.api.core.management.AddressSettingsInfo

getMaxRetryInterval() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the maximum retry interval (in the case a retry interval multiplier has been specified).

getMaxSizeBytes() - Method in class org.hornetq.api.core.management.AddressSettingsInfo

getMessageCount() - Method in interface org.hornetq.api.core.client.ClientSession.QueueQuery

Returns the number of messages in the queue.

getMessageCount() - Method in interface org.hornetq.api.core.management.QueueControl

Returns the number of messages currently in this queue.

getMessageCounterMaxDayCount() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the maximum number of days kept in memory for message counter.

getMessageCounterSamplePeriod() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the sample period (in milliseconds) to take message counter snapshot.

getMessageExpiryScanPeriod() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the frequency (in milliseconds) to scan messages to detect which messages have expired.

getMessageExpiryThreadPriority() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the priority of the thread used to scan message expiration.

getMessageHandler() - Method in interface org.hornetq.api.core.client.ClientConsumer

Returns the MessageHandler associated to this consumer.

getMessageID() - Method in interface org.hornetq.api.core.Message

Returns the messageID.

getMessagesAdded() - Method in interface org.hornetq.api.core.management.QueueControl

Returns the number of messages added to this queue since it was created.

getMinLargeMessageSize() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the large message size threshold.

getName() - Method in class org.hornetq.api.core.BroadcastGroupConfiguration

getName() - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration

getName() - Method in interface org.hornetq.api.core.management.AcceptorControl

Returns the name of the acceptor

getName() - Method in interface org.hornetq.api.core.management.BridgeControl

Returns the name of this bridge

getName() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl

Returns the configuration name of this broadcast group.

getName() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl

Returns the configuration name of this cluster connection.

getName() - Method in interface org.hornetq.api.core.management.QueueControl

Returns the name of this queue.

getName() - Method in class org.hornetq.api.core.management.RoleInfo

Returns the name of the role.

getName() - Method in class org.hornetq.api.core.TransportConfiguration

Returns the name of this TransportConfiguration.

getNodeId() - Method in interface org.hornetq.api.core.client.TopologyMember

Returns the nodeId of the server.

getNodeID() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl

Returns the node ID used by this cluster connection.

getNodes() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl

Returns a map of the nodes connected to this cluster connection.

getNumberOfBytesPerPage() - Method in interface org.hornetq.api.core.management.AddressControl

Returns the number of bytes used by each page for this address.

getNumberOfPages() - Method in interface org.hornetq.api.core.management.AddressControl

Returns the number of pages used by this address.

getObjectProperty(SimpleString) - Method in interface org.hornetq.api.core.Message

Returns the property corresponding to the specified key

getObjectProperty(String) - Method in interface org.hornetq.api.core.Message

getOutgoingInterceptorClassNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the list of interceptors used by this server for outgoing messages.

getPageCacheMaxSize() - Method in class org.hornetq.api.core.management.AddressSettingsInfo

getPageSizeBytes() - Method in class org.hornetq.api.core.management.AddressSettingsInfo

getPagingDirectory() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the file system directory used to store paging files.

getParameters() - Method in interface org.hornetq.api.core.management.AcceptorControl

Returns the parameters used to configure this acceptor

getParams() - Method in class org.hornetq.api.core.TransportConfiguration

Returns any parameters set for this TransportConfiguration

getPriority() - Method in interface org.hornetq.api.core.Message

Returns the message priority.

getProducerMaxRate() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the maximum rate of message production for producers created through this factory.

getProducerWindowSize() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the window size for flow control of the producers created through this factory.

getPropertyNames() - Method in interface org.hornetq.api.core.Message

Returns all the names of the properties for this message.

getPropMaskPassword() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getPropPasswordCodec() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

getQueueName() - Method in interface org.hornetq.api.core.management.BridgeControl

Returns the name of the queue this bridge is consuming messages from.

getQueueNames() - Method in interface org.hornetq.api.core.client.ClientSession.BindingQuery

Returns the names of the queues bound to the binding.

getQueueNames() - Method in interface org.hornetq.api.core.management.AddressControl

Returns the names of the queues bound to this address.

getQueueNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the names of the queues created on this server.

getQueueObjectName(SimpleString, SimpleString) - Method in class org.hornetq.api.core.management.ObjectNameBuilder

Returns the ObjectName used by QueueControl.

getReconnectAttempts() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the maximum number of attempts to retry connection in case of failure.

getReconnectAttempts() - Method in interface org.hornetq.api.core.management.BridgeControl

Returns the number of reconnection attempts used by this bridge.

getRedeliveryDelay() - Method in class org.hornetq.api.core.management.AddressSettingsInfo

getRedeliveryMultiplier() - Method in class org.hornetq.api.core.management.AddressSettingsInfo

getRedistributionDelay() - Method in class org.hornetq.api.core.management.AddressSettingsInfo

getRefreshTimeout() - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration

getRemoteAddress() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

returns a string representation of the remote address of this connection

getRemoteAddress() - Method in interface org.hornetq.spi.core.remoting.Connection

Returns a string representation of the remote address this connection is connected to.

getResult(Message) - Static method in class org.hornetq.api.core.management.ManagementHelper

Returns the result of an operation invocation or an attribute value.

getResults(Message) - Static method in class org.hornetq.api.core.management.ManagementHelper

Returns the result of an operation invocation or an attribute value.

getRetryInterval() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the time to retry connections created by this factory after failure.

getRetryInterval() - Method in interface org.hornetq.api.core.management.BridgeControl

Returns the retry interval used by this bridge.

getRetryInterval() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl

Returns the connection retry interval used by this cluster connection.

getRetryIntervalMultiplier() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the multiplier to apply to successive retry intervals.

getRetryIntervalMultiplier() - Method in interface org.hornetq.api.core.management.BridgeControl

Returns the retry interval multiplier used by this bridge.

getRoles() - Method in interface org.hornetq.api.core.management.AddressControl

Returns the roles (name and permissions) associated to this address.

getRoles(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

getRolesAsJSON() - Method in interface org.hornetq.api.core.management.AddressControl

Returns the roles (name and permissions) associated to this address using JSON serialization.

getRolesAsJSON(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

getRoutingName() - Method in interface org.hornetq.api.core.management.DivertControl

Returns the routing name of this divert.

getScheduledCount() - Method in interface org.hornetq.api.core.management.QueueControl

Returns the number of scheduled messages in this queue.

getScheduledThreadPoolMaxSize() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the maximum size of the scheduled thread pool.

getScheduledThreadPoolMaxSize() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the maximum number of threads in the scheduled thread pool.

getSecurityInvalidationInterval() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the interval time (in milliseconds) to invalidate security credentials.

getServerLocator() - Method in interface org.hornetq.api.core.client.ClientSessionFactory

getShortProperty(SimpleString) - Method in interface org.hornetq.api.core.Message

Returns the property corresponding to the specified key as a Short.

getShortProperty(String) - Method in interface org.hornetq.api.core.Message

getSimpleStringProperty(SimpleString) - Method in interface org.hornetq.api.core.Message

Returns the property corresponding to the specified key as a SimpleString.

getSimpleStringProperty(String) - Method in interface org.hornetq.api.core.Message

getStaticConnectors() - Method in interface org.hornetq.api.core.management.BridgeControl

Returns any list of static connectors used by this bridge

getStaticConnectors() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl

Returns the list of static connectors

getStaticConnectorsAsJSON() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl

Returns the list of static connectors as JSON

getStaticTransportConfigurations() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns an array of TransportConfigurations representing the static list of live servers used when creating this object

getStringProperty(SimpleString) - Method in interface org.hornetq.api.core.Message

Returns the property corresponding to the specified key as a String.

getStringProperty(String) - Method in interface org.hornetq.api.core.Message

getThreadPoolMaxSize() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the maximum size of the thread pool.

getThreadPoolMaxSize() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the maximum number of threads in the thread pool.

getTimestamp() - Method in interface org.hornetq.api.core.Message

Returns the message timestamp.

getTopology() - Method in interface org.hornetq.api.core.client.ServerLocator

Exposes the Topology used by this ServerLocator.

getTopology() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl

Return the Topology that this Cluster Connection knows about

getTransactionTimeout() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the timeout (in milliseconds) after which transactions is removed from the resource manager after it was created.

getTransactionTimeoutScanPeriod() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns the frequency (in milliseconds) to scan transactions to detect which transactions have timed out.

getTransformerClassName() - Method in interface org.hornetq.api.core.management.BridgeControl

Return the name of the org.hornetq.core.server.cluster.Transformer implementation associated to this bridge.

getTransformerClassName() - Method in interface org.hornetq.api.core.management.DivertControl

Return the name of the org.hornetq.core.server.cluster.Transformer implementation associated to this bridge.

getTransportConnection() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

return the underlying Connection.

getType() - Method in interface org.hornetq.api.core.Message

Returns this message type.

getUniqueEventID() - Method in interface org.hornetq.api.core.client.TopologyMember

getUniqueName() - Method in interface org.hornetq.api.core.management.DivertControl

Returns the cluster-wide unique name of this divert.

getUserID() - Method in interface org.hornetq.api.core.Message

Returns the userID - this is an optional user specified UUID that can be set to identify the message and will be passed around with the message

getVersion() - Method in interface org.hornetq.api.core.client.ClientSession

Returns the server's incrementingVersion.

getVersion() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns this server's version.

getXAResource() - Method in interface org.hornetq.api.core.client.ClientSession

Returns the XAResource associated to the session.

H

hashCode() - Method in class org.hornetq.api.core.BroadcastGroupConfiguration

hashCode() - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration

hashCode() - Method in class org.hornetq.api.core.TransportConfiguration

hashCode() - Method in class org.hornetq.api.core.UDPBroadcastGroupConfiguration

hasOperationSucceeded(Message) - Static method in class org.hornetq.api.core.management.ManagementHelper

Returns whether the invocation of the management operation on the server resource succeeded.

HDR_ACTUAL_EXPIRY_TIME - Static variable in interface org.hornetq.api.core.Message

HDR_ADDRESS - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_ATTRIBUTE - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_BINDING_ID - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_BINDING_TYPE - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_CHECK_TYPE - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_CLUSTER_NAME - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_CONSUMER_COUNT - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_DISTANCE - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_DUPLICATE_DETECTION_ID - Static variable in interface org.hornetq.api.core.Message

HDR_FILTERSTRING - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_GROUP_ID - Static variable in interface org.hornetq.api.core.Message

HDR_LARGE_BODY_SIZE - Static variable in interface org.hornetq.api.core.Message

HDR_LARGE_COMPRESSED - Static variable in interface org.hornetq.api.core.Message

HDR_LAST_VALUE_NAME - Static variable in interface org.hornetq.api.core.Message

HDR_NOTIFICATION_TIMESTAMP - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_NOTIFICATION_TYPE - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_OPERATION_NAME - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_OPERATION_SUCCEEDED - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_ORIG_MESSAGE_ID - Static variable in interface org.hornetq.api.core.Message

HDR_ORIGINAL_ADDRESS - Static variable in interface org.hornetq.api.core.Message

HDR_ORIGINAL_QUEUE - Static variable in interface org.hornetq.api.core.Message

HDR_PROPOSAL_ALT_VALUE - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_PROPOSAL_GROUP_ID - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_PROPOSAL_VALUE - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_REMOTE_ADDRESS - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_RESOURCE_NAME - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_ROUTING_NAME - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_SCHEDULED_DELIVERY_TIME - Static variable in interface org.hornetq.api.core.Message

HDR_SESSION_NAME - Static variable in class org.hornetq.api.core.management.ManagementHelper

HDR_USER - Static variable in class org.hornetq.api.core.management.ManagementHelper

HORNETQ_DURABLE - Static variable in class org.hornetq.api.core.FilterConstants

Name of the HornetQ Message durable header.

HORNETQ_EXPIRATION - Static variable in class org.hornetq.api.core.FilterConstants

Name of the HornetQ Message expiration header.

HORNETQ_PREFIX - Static variable in class org.hornetq.api.core.FilterConstants

All HornetQ headers are prepended by this prefix.

HORNETQ_PRIORITY - Static variable in class org.hornetq.api.core.FilterConstants

Name of the HornetQ Message priority header.

HORNETQ_SIZE - Static variable in class org.hornetq.api.core.FilterConstants

Name of the HornetQ Message size header.

HORNETQ_TIMESTAMP - Static variable in class org.hornetq.api.core.FilterConstants

Name of the HornetQ Message timestamp header.

HORNETQ_USERID - Static variable in class org.hornetq.api.core.FilterConstants

Name of the HornetQ UserID header.

HornetQClient - Class in org.hornetq.api.core.client

Utility class for creating HornetQ ClientSessionFactory objects.

HornetQComponentControl - Interface in org.hornetq.api.core.management

A HornetQComponentControl is used to manage the life cycle of a HornetQ component.

HornetQDefaultConfiguration - Class in org.hornetq.api.config

Default values of HornetQ configuration parameters.

HornetQServerControl - Interface in org.hornetq.api.core.management

A HornetQServerControl is used to manage HornetQ servers.

I

individualAcknowledge() - Method in interface org.hornetq.api.core.client.ClientMessage

Acknowledge reception of a single message.

INITIAL_CONNECT_ATTEMPTS - Static variable in class org.hornetq.api.core.client.HornetQClient

intercept(Packet, RemotingConnection) - Method in interface org.hornetq.api.core.Interceptor

Intercepts a packet which is received before it is sent to the channel

Interceptor - Interface in org.hornetq.api.core

This is class is a simple way to intercepting calls on HornetQ client and servers.

intValue() - Method in enum org.hornetq.api.core.management.NotificationType

isAsyncConnectionExecutionEnabled() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns whether code coming from connection is executed asynchronously or not.

isAttributesResult(Message) - Static method in class org.hornetq.api.core.management.ManagementHelper

Returns whether the JMS message corresponds to the result of a management attribute value.

isAutoCommitAcks() - Method in interface org.hornetq.api.core.client.ClientSession

Returns whether the session will automatically commit its transaction every time a message is acknowledged by a ClientConsumer created by this session, false else

isAutoCommitSends() - Method in interface org.hornetq.api.core.client.ClientSession

Returns whether the session will automatically commit its transaction every time a message is sent by a ClientProducer created by this session, false else

isAutoGroup() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns whether producers created through this factory will automatically assign a group ID to the messages they sent.

isBackup() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns true if this server is a backup, false if it is a live server.

isBlockOnAcknowledge() - Method in interface org.hornetq.api.core.client.ClientSession

Returns whether the ClientConsumer created by the session will block when they acknowledge a message.

isBlockOnAcknowledge() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns whether consumers created through this factory will block while sending message acknowledgments or do it asynchronously.

isBlockOnDurableSend() - Method in interface org.hornetq.api.core.client.ClientProducer

Returns whether the producer will block when sending durable messages.

isBlockOnDurableSend() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns whether producers created through this factory will block while sending durable messages or do it asynchronously.

isBlockOnNonDurableSend() - Method in interface org.hornetq.api.core.client.ClientProducer

Returns whether the producer will block when sending non-durable messages.

isBlockOnNonDurableSend() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns whether producers created through this factory will block while sending non-durable messages or do it asynchronously.

isCacheLargeMessagesClient() - Method in interface org.hornetq.api.core.client.ServerLocator

When true, consumers created through this factory will create temporary files to cache large messages.

isClient() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

Returns whether or not the RemotingConnection is a client

isClosed() - Method in interface org.hornetq.api.core.client.ClientConsumer

Returns whether the consumer is closed or not.

isClosed() - Method in interface org.hornetq.api.core.client.ClientProducer

Returns whether the producer is closed or not.

isClosed() - Method in interface org.hornetq.api.core.client.ClientSession

Returns whether the session is closed or not.

isClosed() - Method in interface org.hornetq.api.core.client.ClientSessionFactory

isClosed() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns true if close was already called

isClustered() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns whether this server is clustered.

isCompressLargeMessage() - Method in interface org.hornetq.api.core.client.ServerLocator

Whether to compress large messages.

isConsume() - Method in class org.hornetq.api.core.management.RoleInfo

Returns whether this role can consume messages from queues bound to the address.

isCreateBindingsDir() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns whether the bindings directory is created on this server startup.

isCreateDurableQueue() - Method in class org.hornetq.api.core.management.RoleInfo

Returns whether this role can create durable queues bound to the address.

isCreateJournalDir() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns whether the journal directory is created on this server startup.

isCreateNonDurableQueue() - Method in class org.hornetq.api.core.management.RoleInfo

Returns whether this role can create non-durable queues bound to the address.

isDefaultAllowAutoFailback() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultAsyncConnectionExecutionEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultBackup() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultBridgeDuplicateDetection() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultCheckForLiveServer() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultClusterDuplicateDetection() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultClusterForwardWhenNoConsumers() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultCreateBindingsDir() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultCreateJournalDir() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultDivertExclusive() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultFailoverOnServerShutdown() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultFileDeploymentEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultJmxManagementEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultJournalLogWriteRate() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultJournalSyncNonTransactional() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultJournalSyncTransactional() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultMaskPassword() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultMessageCounterEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultPersistDeliveryCountBeforeDelivery() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultPersistenceEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultPersistIdCache() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultRunSyncSpeedTest() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultSecurityEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultSharedStore() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDefaultWildcardRoutingEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration

isDeleteDurableQueue() - Method in class org.hornetq.api.core.management.RoleInfo

Returns whether this role can delete durable queues bound to the address.

isDeleteNonDurableQueue() - Method in class org.hornetq.api.core.management.RoleInfo

Returns whether this role can delete non-durable queues bound to the address.

isDestroyed() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

Returns true if this RemotingConnection has been destroyed.

isDuplicateDetection() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl

Return whether this cluster connection use duplicate detection.

isDurable() - Method in interface org.hornetq.api.core.client.ClientSession.QueueQuery

Returns true if the queue is durable, false else.

isDurable() - Method in interface org.hornetq.api.core.management.QueueControl

Returns whether this queue is durable.

isDurable() - Method in interface org.hornetq.api.core.Message

Returns whether this message is durable or not.

isEquivalent(TransportConfiguration) - Method in class org.hornetq.api.core.TransportConfiguration

There's a case on ClusterConnections that we need to find an equivalent Connector and we can't use a Netty Cluster Connection on an InVM ClusterConnection (inVM used on tests) for that reason I need to test if the two instances of the TransportConfiguration are equivalent while a test a connector against an acceptor

isEquivalent(Map<String, Object>) - Method in interface org.hornetq.spi.core.remoting.Connector

If the configuration is equivalent to this connector, which means if the parameter configuration is used to create a connection to a target node, it will be the same node as of the connections made with this connector.

isExclusive() - Method in interface org.hornetq.api.core.management.DivertControl

Returns whether this divert is exclusive.

isExists() - Method in interface org.hornetq.api.core.client.ClientSession.BindingQuery

Returns true if the binding exists, false else.

isExists() - Method in interface org.hornetq.api.core.client.ClientSession.QueueQuery

Returns true if the queue exists, false else.

isExpired() - Method in interface org.hornetq.api.core.Message

Returns whether this message is expired or not.

isFailoverOnInitialConnection() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns true if the client will automatically attempt to connect to the backup server if the initial connection to the live server fails Default value is HornetQClient.DEFAULT_FAILOVER_ON_INITIAL_CONNECTION.

isFailoverOnServerShutdown() - Method in interface org.hornetq.api.core.management.HornetQServerControl

returns if clients failover on a server shutdown

isForwardWhenNoConsumers() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl

Return whether this cluster connection forward messages when it has no local consumers.

isHA() - Method in interface org.hornetq.api.core.client.ServerLocator

Whether this server receives topology notifications from the cluster as servers join or leave the cluster.

isHA() - Method in interface org.hornetq.api.core.management.BridgeControl

Returns whether this bridge is using high availability

isJournalSyncNonTransactional() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns whether the journal is synchronized when receiving non-transactional data.

isJournalSyncTransactional() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns whether the journal is synchronized when receiving transactional data.

isLargeMessage() - Method in interface org.hornetq.api.core.Message

Returns whether this message is a large message or a regular message.

isLastValueQueue() - Method in class org.hornetq.api.core.management.AddressSettingsInfo

isManage() - Method in class org.hornetq.api.core.management.RoleInfo

Returns whether this role can send management messages to the address.

isMessageCounterEnabled() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns whether message counter is enabled for this server.

isOperationResult(Message) - Static method in class org.hornetq.api.core.management.ManagementHelper

Returns whether the JMS message corresponds to the result of a management operation invocation.

isPaging() - Method in interface org.hornetq.api.core.management.AddressControl

Returns whether this address is paging.

isPaused() - Method in interface org.hornetq.api.core.management.QueueControl

Returns whether the queue is paused.

isPersistDeliveryCountBeforeDelivery() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns whether delivery count is persisted before messages are delivered to the consumers.

isPersistenceEnabled() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns whether this server is using persistence and store data.

isPersistIDCache() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns whether message ID cache is persisted.

isPreAcknowledge() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns whether messages will pre-acknowledged on the server before they are sent to the consumers or not.

isReadyToHandle(HornetQBuffer) - Method in interface org.hornetq.spi.core.remoting.BufferDecoder

called by the remoting system prior to BufferHandler.bufferReceived(Object, org.hornetq.api.core.HornetQBuffer).

isRollbackOnly() - Method in interface org.hornetq.api.core.client.ClientSession

Returns true if the current transaction has been flagged to rollback, false else.

isSecurityEnabled() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns whether security is enabled for this server.

isSend() - Method in class org.hornetq.api.core.management.RoleInfo

Returns whether this role can send messages to the address.

isSendToDLAOnNoRoute() - Method in class org.hornetq.api.core.management.AddressSettingsInfo

isSharedStore() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns whether this server shares its data store with a corresponding live or backup server.

isStarted() - Method in interface org.hornetq.api.core.management.HornetQComponentControl

Returns true if this component is started, false else.

isStarted() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Return whether this server is started.

isStarted() - Method in interface org.hornetq.spi.core.remoting.Connector

returns true if the connector is started, oterwise false.

isTemporary() - Method in interface org.hornetq.api.core.management.QueueControl

Returns whether this queue is temporary.

isUseDuplicateDetection() - Method in interface org.hornetq.api.core.management.BridgeControl

Returns whether this bridge is using duplicate detection.

isUseGlobalPools() - Method in interface org.hornetq.api.core.client.ServerLocator

Returns whether this factory will use global thread pools (shared among all the factories in the same JVM) or its own pools.

isWildcardRoutingEnabled() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Returns whether wildcard routing is supported by this server.

isXA() - Method in interface org.hornetq.api.core.client.ClientSession

Return true if the session supports XA, false else.

J

JGroupsBroadcastGroupConfiguration - Class in org.hornetq.api.core

The configuration for creating broadcasting/discovery groups using JGroups channels There are two ways to constructing a JGroups channel (JChannel): by passing in a JGroups configuration file The file must exists in the hornetq classpath.

JGroupsBroadcastGroupConfiguration(String, String) - Constructor for class org.hornetq.api.core.JGroupsBroadcastGroupConfiguration

JGroupsBroadcastGroupConfiguration(JChannel, String) - Constructor for class org.hornetq.api.core.JGroupsBroadcastGroupConfiguration

JMS_CONNECTION_FACTORY - Static variable in class org.hornetq.api.core.management.ResourceNames

JMS_QUEUE - Static variable in class org.hornetq.api.core.management.ResourceNames

JMS_SERVER - Static variable in class org.hornetq.api.core.management.ResourceNames

JMS_TOPIC - Static variable in class org.hornetq.api.core.management.ResourceNames

L

lastCheck - Variable in class org.hornetq.spi.core.protocol.ConnectionEntry

listConnectionIDs() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Lists all the IDs of the connections connected to this server.

listConsumersAsJSON() - Method in interface org.hornetq.api.core.management.QueueControl

listDeliveringdMessagesAsJSON() - Method in interface org.hornetq.api.core.management.QueueControl

Executes a conversion of QueueControl.listDeliveringMessages() to JSON

listDeliveringMessages() - Method in interface org.hornetq.api.core.management.QueueControl

Lists all the messages being deliver per consumer.

listHeuristicCommittedTransactions() - Method in interface org.hornetq.api.core.management.HornetQServerControl

List transactions which have been heuristically committed.

listHeuristicRolledBackTransactions() - Method in interface org.hornetq.api.core.management.HornetQServerControl

List transactions which have been heuristically rolled back.

listMessageCounter() - Method in interface org.hornetq.api.core.management.QueueControl

Lists the message counter for this queue.

listMessageCounterAsHTML() - Method in interface org.hornetq.api.core.management.QueueControl

Lists the message counter for this queue as a HTML table.

listMessageCounterHistory() - Method in interface org.hornetq.api.core.management.QueueControl

Lists the message counter history for this queue.

listMessageCounterHistoryAsHTML() - Method in interface org.hornetq.api.core.management.QueueControl

Lists the message counter history for this queue as a HTML table.

listMessages(String) - Method in interface org.hornetq.api.core.management.QueueControl

Lists all the messages in this queue matching the specified filter.

listMessagesAsJSON(String) - Method in interface org.hornetq.api.core.management.QueueControl

Lists all the messages in this queue matching the specified filter using JSON serialization.

listPreparedTransactionDetailsAsHTML() - Method in interface org.hornetq.api.core.management.HornetQServerControl

List all the prepared transaction, sorted by date, oldest first, with details, in HTML format

listPreparedTransactionDetailsAsJSON() - Method in interface org.hornetq.api.core.management.HornetQServerControl

List all the prepared transaction, sorted by date, oldest first, with details, in text format.

listPreparedTransactions() - Method in interface org.hornetq.api.core.management.HornetQServerControl

List all the prepared transaction, sorted by date, oldest first.

listProducersInfoAsJSON() - Method in interface org.hornetq.api.core.management.HornetQServerControl

listRemoteAddresses() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Lists the addresses of all the clients connected to this address.

listRemoteAddresses(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

Lists the addresses of the clients connected to this address which matches the specified IP address.

listScheduledMessages() - Method in interface org.hornetq.api.core.management.QueueControl

Lists all the messages scheduled for delivery for this queue.

listScheduledMessagesAsJSON() - Method in interface org.hornetq.api.core.management.QueueControl

Lists all the messages scheduled for delivery for this queue using JSON serialization.

listSessions(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

Lists all the sessions IDs for the specified connection ID.

M

ManagementHelper - Class in org.hornetq.api.core.management

Helper class to use HornetQ Core messages to manage server resources.

MAP_TYPE - Static variable in interface org.hornetq.api.core.Message

Message - Interface in org.hornetq.api.core

A Message is a routable instance that has a payload.

MessageHandler - Interface in org.hornetq.api.core.client

A MessageHandler is used to receive message asynchronously.

moveMessage(long, String) - Method in interface org.hornetq.api.core.management.QueueControl

Moves the message corresponding to the specified message ID to the specified other queue.

moveMessage(long, String, boolean) - Method in interface org.hornetq.api.core.management.QueueControl

Moves the message corresponding to the specified message ID to the specified other queue.

moveMessages(String, String) - Method in interface org.hornetq.api.core.management.QueueControl

Moves all the message corresponding to the specified filter to the specified other queue.

moveMessages(String, String, boolean) - Method in interface org.hornetq.api.core.management.QueueControl

Moves all the message corresponding to the specified filter to the specified other queue.

N

nodeDown(long, String) - Method in interface org.hornetq.api.core.client.ClusterTopologyListener

Triggered when a node leaves the cluster.

nodeUP(TopologyMember, boolean) - Method in interface org.hornetq.api.core.client.ClusterTopologyListener

Triggered when a node joins the cluster.

NON_DURABLE - Static variable in class org.hornetq.api.core.FilterConstants

Value for the Durable header when the message is non-durable.

NotificationType - Enum in org.hornetq.api.core.management

Types of notification emitted by HornetQ servers.

O

OBJECT_TYPE - Static variable in interface org.hornetq.api.core.Message

ObjectNameBuilder - Class in org.hornetq.api.core.management

Helper class to build ObjectNames for HornetQ resources.

onMessage(ClientMessage) - Method in interface org.hornetq.api.core.client.MessageHandler

Notifies the MessageHandler that a message has been received.

openBroadcaster() - Method in interface org.hornetq.api.core.BroadcastEndpoint

This method initializes a BroadcastEndpint as a broadcaster.

openClient() - Method in interface org.hornetq.api.core.BroadcastEndpoint

This method initializes a BroadcastEndpoint as a receiving end for broadcasts.

Operation - Annotation Type in org.hornetq.api.core.management

Info for a MBean Operation.

org.hornetq.api.config - package org.hornetq.api.config

org.hornetq.api.core - package org.hornetq.api.core

Core Messaging API.

org.hornetq.api.core.client - package org.hornetq.api.core.client

Core Client Messaging API.

org.hornetq.api.core.client.loadbalance - package org.hornetq.api.core.client.loadbalance

Client load-balancing API.

org.hornetq.api.core.management - package org.hornetq.api.core.management

Management API for HornetQ servers and its Core resources.

org.hornetq.spi.core.protocol - package org.hornetq.spi.core.protocol

org.hornetq.spi.core.remoting - package org.hornetq.spi.core.remoting

Remoting SPI.

P

Parameter - Annotation Type in org.hornetq.api.core.management

Info for a MBean Operation Parameter.

pause() - Method in interface org.hornetq.api.core.management.QueueControl

Pauses the queue.

ProtocolType - Enum in org.hornetq.spi.core.protocol

A ProtocolType

putAttribute(Message, String, String) - Static method in class org.hornetq.api.core.management.ManagementHelper

Stores a resource attribute in a message to retrieve the value from the server resource.

putBooleanProperty(SimpleString, boolean) - Method in interface org.hornetq.api.core.Message

Puts a boolean property in this message.

putBooleanProperty(String, boolean) - Method in interface org.hornetq.api.core.Message

putByteProperty(SimpleString, byte) - Method in interface org.hornetq.api.core.Message

Puts a byte property in this message.

putByteProperty(String, byte) - Method in interface org.hornetq.api.core.Message

putBytesProperty(SimpleString, byte[]) - Method in interface org.hornetq.api.core.Message

Puts a byte[] property in this message.

putBytesProperty(String, byte[]) - Method in interface org.hornetq.api.core.Message

putDoubleProperty(SimpleString, double) - Method in interface org.hornetq.api.core.Message

Puts a double property in this message.

putDoubleProperty(String, double) - Method in interface org.hornetq.api.core.Message

putFloatProperty(SimpleString, float) - Method in interface org.hornetq.api.core.Message

Puts a float property in this message.

putFloatProperty(String, float) - Method in interface org.hornetq.api.core.Message

putIntProperty(SimpleString, int) - Method in interface org.hornetq.api.core.Message

Puts a int property in this message.

putIntProperty(String, int) - Method in interface org.hornetq.api.core.Message

putLongProperty(SimpleString, long) - Method in interface org.hornetq.api.core.Message

Puts a long property in this message.

putLongProperty(String, long) - Method in interface org.hornetq.api.core.Message

putObjectProperty(SimpleString, Object) - Method in interface org.hornetq.api.core.Message

Puts an Object property in this message.

putObjectProperty(String, Object) - Method in interface org.hornetq.api.core.Message

putOperationInvocation(Message, String, String) - Static method in class org.hornetq.api.core.management.ManagementHelper

Stores a operation invocation in a message to invoke the corresponding operation the value from the server resource.

putOperationInvocation(Message, String, String, Object...) - Static method in class org.hornetq.api.core.management.ManagementHelper

Stores a operation invocation in a message to invoke the corresponding operation the value from the server resource.

putShortProperty(SimpleString, short) - Method in interface org.hornetq.api.core.Message

Puts a short property in this message.

putShortProperty(String, short) - Method in interface org.hornetq.api.core.Message

putStringProperty(SimpleString, SimpleString) - Method in interface org.hornetq.api.core.Message

Puts a SimpleString property in this message.

putStringProperty(String, String) - Method in interface org.hornetq.api.core.Message

Puts a String property in this message.

Q

QueueControl - Interface in org.hornetq.api.core.management

A QueueControl is used to manage a queue.

queueQuery(SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession

Queries information on a queue.

R

RandomConnectionLoadBalancingPolicy - Class in org.hornetq.api.core.client.loadbalance

RandomConnectionLoadBalancingPolicy.select(int) returns a (pseudo) random integer between 0 (inclusive) and max (exclusive).

RandomConnectionLoadBalancingPolicy() - Constructor for class org.hornetq.api.core.client.loadbalance.RandomConnectionLoadBalancingPolicy

RandomStickyConnectionLoadBalancingPolicy - Class in org.hornetq.api.core.client.loadbalance

RandomConnectionLoadBalancingPolicy.select(int) chooses a the initial node randomly then subsequent requests return the same node

RandomStickyConnectionLoadBalancingPolicy() - Constructor for class org.hornetq.api.core.client.loadbalance.RandomStickyConnectionLoadBalancingPolicy

readyForWriting(boolean) - Method in interface org.hornetq.spi.core.remoting.ReadyListener

ReadyListener - Interface in org.hornetq.spi.core.remoting

A ReadyListener

receive() - Method in interface org.hornetq.api.core.client.ClientConsumer

Receives a message from a queue.

receive(long) - Method in interface org.hornetq.api.core.client.ClientConsumer

Receives a message from a queue.

receiveBroadcast() - Method in interface org.hornetq.api.core.BroadcastEndpoint

Receives the broadcast data.

receiveBroadcast(long, TimeUnit) - Method in interface org.hornetq.api.core.BroadcastEndpoint

Receives the broadcast data with a timeout.

receiveImmediate() - Method in interface org.hornetq.api.core.client.ClientConsumer

Receives a message from a queue.

RemotingConnection - Interface in org.hornetq.spi.core.protocol

A RemotingConnection is a connection between a client and a server.

removeAddressSettings(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

removeCloseListener(CloseListener) - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

remove a Close Listener

removeCloseListeners() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

removeClusterTopologyListener(ClusterTopologyListener) - Method in interface org.hornetq.api.core.client.ServerLocator

removeFailoverListener(FailoverEventListener) - Method in interface org.hornetq.api.core.client.ClientSession

Removes a FailoverEventListener to the session.

removeFailoverListener(FailoverEventListener) - Method in interface org.hornetq.api.core.client.ClientSessionFactory

Removes a FailoverEventListener to the session.

removeFailureListener(SessionFailureListener) - Method in interface org.hornetq.api.core.client.ClientSession

Removes a FailureListener to the session.

removeFailureListener(FailureListener) - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

remove the failure listener

removeFailureListeners() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

removeIncomingInterceptor(Interceptor) - Method in interface org.hornetq.api.core.client.ServerLocator

Removes an incoming interceptor.

removeInterceptor(Interceptor) - Method in interface org.hornetq.api.core.client.ServerLocator

Deprecated. As of HornetQ 2.3.0.Final, replaced by ServerLocator.removeIncomingInterceptor(Interceptor) and ServerLocator.removeOutgoingInterceptor(Interceptor)

removeMessage(long) - Method in interface org.hornetq.api.core.management.QueueControl

Removes the message corresponding to the specified message ID.

removeMessages(String) - Method in interface org.hornetq.api.core.management.QueueControl

Removes all the message corresponding to the specified filter.

removeOutgoingInterceptor(Interceptor) - Method in interface org.hornetq.api.core.client.ServerLocator

Removes an outgoing interceptor.

removeProperty(SimpleString) - Method in interface org.hornetq.api.core.Message

Removes the property corresponding to the specified key.

removeProperty(String) - Method in interface org.hornetq.api.core.Message

removeReadyListener(ReadyListener) - Method in interface org.hornetq.spi.core.remoting.Connection

removeSecuritySettings(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

request(ClientMessage) - Method in class org.hornetq.api.core.client.ClientRequestor

Sends a message to the request address and wait indefinitely for a reply.

request(ClientMessage, long) - Method in class org.hornetq.api.core.client.ClientRequestor

Sends a message to the request address and wait for the given timeout for a reply.

resetAllMessageCounterHistories() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Reset histories for all message counters.

resetAllMessageCounters() - Method in interface org.hornetq.api.core.management.HornetQServerControl

Reset all message counters.

resetMessageCounter() - Method in interface org.hornetq.api.core.management.QueueControl

Resets the message counter for this queue.

ResourceNames - Class in org.hornetq.api.core.management

Helper class used to build resource names used by management messages.

resume() - Method in interface org.hornetq.api.core.management.QueueControl

Resumes the queue.

retrieveOperationParameters(Message) - Static method in class org.hornetq.api.core.management.ManagementHelper

Used by HornetQ management service.

RoleInfo - Class in org.hornetq.api.core.management

Helper class to create Java Objects from the JSON serialization returned by AddressControl.getRolesAsJSON().

rollback() - Method in interface org.hornetq.api.core.client.ClientSession

Rolls back the current transaction.

rollback(boolean) - Method in interface org.hornetq.api.core.client.ClientSession

Rolls back the current transaction.

rollbackPreparedTransaction(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

Heuristically rolls back a prepared transaction.

RoundRobinConnectionLoadBalancingPolicy - Class in org.hornetq.api.core.client.loadbalance

RoundRobinConnectionLoadBalancingPolicy corresponds to a round-robin load-balancing policy.

RoundRobinConnectionLoadBalancingPolicy() - Constructor for class org.hornetq.api.core.client.loadbalance.RoundRobinConnectionLoadBalancingPolicy

S

saveToOutputStream(OutputStream) - Method in interface org.hornetq.api.core.client.ClientMessage

Saves the content of the message to the OutputStream.

select(int) - Method in interface org.hornetq.api.core.client.loadbalance.ConnectionLoadBalancingPolicy

Returns the selected index according to the policy implementation.

select(int) - Method in class org.hornetq.api.core.client.loadbalance.FirstElementConnectionLoadBalancingPolicy

select(int) - Method in class org.hornetq.api.core.client.loadbalance.RandomConnectionLoadBalancingPolicy

Returns a pseudo random number between 0 (inclusive) and max exclusive.

select(int) - Method in class org.hornetq.api.core.client.loadbalance.RandomStickyConnectionLoadBalancingPolicy

select(int) - Method in class org.hornetq.api.core.client.loadbalance.RoundRobinConnectionLoadBalancingPolicy

send(Message) - Method in interface org.hornetq.api.core.client.ClientProducer

Sends a message to an address.

send(SimpleString, Message) - Method in interface org.hornetq.api.core.client.ClientProducer

Sends a message to the specified address instead of the ClientProducer's address.

send(String, Message) - Method in interface org.hornetq.api.core.client.ClientProducer

Sends a message to the specified address instead of the ClientProducer's address.

sendAcknowledged(Message) - Method in interface org.hornetq.api.core.client.SendAcknowledgementHandler

Notifies the client that a message sent asynchronously has been received by the server.

SendAcknowledgementHandler - Interface in org.hornetq.api.core.client

A SendAcknowledgementHandler notifies a client when an message sent asynchronously has been received by the server.

sendMessagesToDeadLetterAddress(String) - Method in interface org.hornetq.api.core.management.QueueControl

Sends all the message corresponding to the specified filter to this queue's dead letter address.

sendMessageToDeadLetterAddress(long) - Method in interface org.hornetq.api.core.management.QueueControl

Sends the message corresponding to the specified message ID to this queue's dead letter address.

sendQueueInfoToQueue(String, String) - Method in interface org.hornetq.api.core.management.HornetQServerControl

This method is used by HornetQ clustering and must not be called by HornetQ clients.

ServerLocator - Interface in org.hornetq.api.core.client

The serverLocator locates a server, but beyond that it locates a server based on a list.

SessionFailureListener - Interface in org.hornetq.api.core.client

A SessionFailureListener notifies the client when a failure occurred on the session.

setAckBatchSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the acknowledgments batch size.

setAddress(SimpleString) - Method in interface org.hornetq.api.core.Message

Sets the address to send this message to.

setAutoGroup(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets whether producers created through this factory will automatically assign a group ID to the messages they sent.

setBlockOnAcknowledge(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets whether consumers created through this factory will block while sending message acknowledgments or do it asynchronously.

setBlockOnDurableSend(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets whether producers created through this factory will block while sending durable messages or do it asynchronously.

setBlockOnNonDurableSend(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets whether producers created through this factory will block while sending non-durable messages or do it asynchronously.

setBodyInputStream(InputStream) - Method in interface org.hornetq.api.core.client.ClientMessage

Sets the body's IntputStream.

setBroadcastPeriod(long) - Method in class org.hornetq.api.core.BroadcastGroupConfiguration

setCacheLargeMessagesClient(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets whether large messages received by consumers created through this factory will be cached in temporary files or not.

setCallFailoverTimeout(long) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the blocking call failover timeout.

setCallTimeout(long) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the blocking call timeout.

setClientFailureCheckPeriod(long) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the period (in milliseconds) used to check if a client has failed to receive pings from the server.

setCloseListeners(List<CloseListener>) - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

setCompressLargeMessage(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets whether to compress or not large messages.

setConfirmationWindowSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the size for the confirmation window buffer of clients using this factory.

setConnectionLoadBalancingPolicyClassName(String) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the class name of the connection load balancing policy.

setConnectionTTL(long) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets this factory's connections time-to-live.

setConnectorInfos(List<String>) - Method in class org.hornetq.api.core.BroadcastGroupConfiguration

setConsumerMaxRate(int) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the maximum rate of message consumption for consumers created through this factory.

setConsumerWindowSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the window size for flow control of the consumers created through this factory.

setDeadLetterAddress(String) - Method in interface org.hornetq.api.core.management.QueueControl

Sets the dead-letter address associated to this queue to the specified deadLetterAddress.

setDeliveryCount(int) - Method in interface org.hornetq.api.core.client.ClientMessage

Set the delivery count for this message.

setDiscoveryInitialWaitTimeout(long) - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration

setDurable(boolean) - Method in interface org.hornetq.api.core.Message

Sets whether this message is durable or not.

setExpiration(long) - Method in interface org.hornetq.api.core.Message

Sets the expiration of this message.

setExpiryAddress(String) - Method in interface org.hornetq.api.core.management.QueueControl

Sets the expiry address associated to this queue to the specified expiryAddress.

setFailoverOnInitialConnection(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the value for FailoverOnInitialReconnection

setFailoverOnServerShutdown(boolean) - Method in interface org.hornetq.api.core.management.HornetQServerControl

do any clients failover on a server shutdown

setFailureListeners(List<FailureListener>) - Method in interface org.hornetq.spi.core.protocol.RemotingConnection

set the failure listeners.

setGroupID(String) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the group ID that will be set on each message sent through this factory.

setInitialConnectAttempts(int) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the maximum number of attempts to establish an initial connection.

setInitialMessagePacketSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the initial size of messages created through this factory.

setMaxRetryInterval(long) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the maximum retry interval.

setMessageCounterMaxDayCount(int) - Method in interface org.hornetq.api.core.management.HornetQServerControl

Sets the maximum number of days kept in memory for message counter.

setMessageCounterSamplePeriod(long) - Method in interface org.hornetq.api.core.management.HornetQServerControl

Sets the sample period to take message counter snapshot.

setMessageHandler(MessageHandler) - Method in interface org.hornetq.api.core.client.ClientConsumer

Sets the MessageHandler for this consumer to consume messages asynchronously.

setMinLargeMessageSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the large message size threshold.

setName(String) - Method in class org.hornetq.api.core.BroadcastGroupConfiguration

setName(String) - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration

setOutputStream(OutputStream) - Method in interface org.hornetq.api.core.client.ClientMessage

Sets the OutputStream that will receive the content of a message received in a non blocking way.

setPageCacheMaxSize(int) - Method in class org.hornetq.api.core.management.AddressSettingsInfo

setPreAcknowledge(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets to true to pre-acknowledge consumed messages on the server before they are sent to consumers, else set to false to let clients acknowledge the message they consume.

setPriority(byte) - Method in interface org.hornetq.api.core.Message

Sets the message priority.

setProducerMaxRate(int) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the maximum rate of message production for producers created through this factory.

setProducerWindowSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator

Returns the window size for flow control of the producers created through this factory.

setReconnectAttempts(int) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the maximum number of attempts to retry connection in case of failure.

setRefreshTimeout(long) - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration

setRetryInterval(long) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the time to retry connections created by this factory after failure.

setRetryIntervalMultiplier(double) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the multiplier to apply to successive retry intervals.

setScheduledThreadPoolMaxSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the maximum size of the scheduled thread pool.

setSendAcknowledgementHandler(SendAcknowledgementHandler) - Method in interface org.hornetq.api.core.client.ClientSession

Sets a SendAcknowledgementHandler for this session.

setThreadPoolMaxSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets the maximum size of the thread pool.

setTimestamp(long) - Method in interface org.hornetq.api.core.Message

Sets the message timestamp.

setUseGlobalPools(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator

Sets whether this factory will use global thread pools (shared among all the factories in the same JVM) or its own pools.

setUserID(UUID) - Method in interface org.hornetq.api.core.Message

Sets the user ID

splitHosts(String) - Static method in class org.hornetq.api.core.TransportConfiguration

Utility method for splitting a comma separated list of hosts

start() - Method in interface org.hornetq.api.core.client.ClientSession

Starts the session.

start() - Method in interface org.hornetq.api.core.management.HornetQComponentControl

Starts this component.

start() - Method in interface org.hornetq.spi.core.remoting.Connector

starts the connector

stop() - Method in interface org.hornetq.api.core.client.ClientSession

Stops the session.

stop() - Method in interface org.hornetq.api.core.management.HornetQComponentControl

Stops this component.

storeResult(Message, Object) - Static method in class org.hornetq.api.core.management.ManagementHelper

Used by HornetQ management service.

STREAM_TYPE - Static variable in interface org.hornetq.api.core.Message

T

TEXT_TYPE - Static variable in interface org.hornetq.api.core.Message

toJSON(DayCounterInfo[]) - Static method in class org.hornetq.api.core.management.DayCounterInfo

toMap() - Method in interface org.hornetq.api.core.Message

TopologyMember - Interface in org.hornetq.api.core.client

A member of the topology.

toString() - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration

toString() - Method in class org.hornetq.api.core.TransportConfiguration

TransportConfiguration - Class in org.hornetq.api.core

A TransportConfiguration is used by a client to specify connections to a server and its backup if one exists.

TransportConfiguration() - Constructor for class org.hornetq.api.core.TransportConfiguration

Creates a default TransportConfiguration with no configured transport.

TransportConfiguration(String, Map<String, Object>, String) - Constructor for class org.hornetq.api.core.TransportConfiguration

Creates a TransportConfiguration with a specific name providing the class name of the ConnectorFactory and any parameters needed.

TransportConfiguration(String, Map<String, Object>) - Constructor for class org.hornetq.api.core.TransportConfiguration

Creates a TransportConfiguration providing the class name of the ConnectorFactory and any parameters needed.

TransportConfiguration(String) - Constructor for class org.hornetq.api.core.TransportConfiguration

Creates a TransportConfiguration providing the class name of the ConnectorFactory

ttl - Variable in class org.hornetq.spi.core.protocol.ConnectionEntry

U

UDPBroadcastGroupConfiguration - Class in org.hornetq.api.core

The configuration used to determine how the server will broadcast members.

UDPBroadcastGroupConfiguration(String, int, String, int) - Constructor for class org.hornetq.api.core.UDPBroadcastGroupConfiguration

V

valueOf(String) - Static method in enum org.hornetq.api.core.client.FailoverEventType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.hornetq.api.core.management.NotificationType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.hornetq.spi.core.protocol.ProtocolType

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.hornetq.api.core.client.FailoverEventType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.hornetq.api.core.management.NotificationType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.hornetq.spi.core.protocol.ProtocolType

Returns an array containing the constants of this enum type, in the order they are declared.

W

waitOutputStreamCompletion(long) - Method in interface org.hornetq.api.core.client.ClientMessage

Wait the outputStream completion of the message.

write(HornetQBuffer, boolean, boolean) - Method in interface org.hornetq.spi.core.remoting.Connection

writes the buffer to the connection and if flush is true returns only when the buffer has been physically written to the connection.

write(HornetQBuffer) - Method in interface org.hornetq.spi.core.remoting.Connection

writes the buffer to the connection with no flushing or batching

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