- AbstractControl - Class in org.hornetq.core.management.impl
-
A AbstractControl
- AbstractControl(Class<?>, StorageManager) - Constructor for class org.hornetq.core.management.impl.AbstractControl
-
- Acceptor - Interface in org.hornetq.spi.core.remoting
-
An Acceptor is used by the RemotingService to allow clients to connect.
- AcceptorControlImpl - Class in org.hornetq.core.management.impl
-
A AcceptorControl
- AcceptorControlImpl(Acceptor, StorageManager, TransportConfiguration) - Constructor for class org.hornetq.core.management.impl.AcceptorControlImpl
-
- acceptorExists(Integer) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- AcceptorFactory - Interface in org.hornetq.spi.core.remoting
-
A factory for creating acceptors.
- acceptorNotExists(Integer) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- ack(PagedReference) - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- AckDescribe(JournalStorageManager.RefEncoding) - Constructor for class org.hornetq.core.persistence.impl.journal.JournalStorageManager.AckDescribe
-
- acknowledge() - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- acknowledge() - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- acknowledge(MessageReference) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- acknowledge(Transaction, MessageReference) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- acknowledge(boolean, Transaction, long) - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- acknowledge(long, long) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- acknowledge() - Method in interface org.hornetq.core.server.MessageReference
-
- acknowledge(MessageReference) - Method in interface org.hornetq.core.server.Queue
-
- acknowledge(Transaction, MessageReference) - Method in interface org.hornetq.core.server.Queue
-
- acknowledge(boolean, Transaction, long) - Method in interface org.hornetq.core.server.ServerConsumer
-
- acknowledge(long, long) - Method in interface org.hornetq.core.server.ServerSession
-
- ACKNOWLEDGE_CURSOR - Static variable in class org.hornetq.core.persistence.impl.journal.JournalRecordIds
-
- ACKNOWLEDGE_REF - Static variable in class org.hornetq.core.persistence.impl.journal.JournalRecordIds
-
- ackTx(Transaction, PagedReference) - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- activate() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- ActivateCallback - Interface in org.hornetq.core.server
-
A ActivateCallback
- activated() - Method in interface org.hornetq.core.server.ActivateCallback
-
- activated() - Method in class org.hornetq.core.server.cluster.BackupManager
-
- activationForServer(HornetQServer) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- ADD_LARGE_MESSAGE - Static variable in class org.hornetq.core.persistence.impl.journal.JournalRecordIds
-
- ADD_LARGE_MESSAGE_PENDING - Static variable in class org.hornetq.core.persistence.impl.journal.JournalRecordIds
-
This is used when a large message is created but not yet stored on the system.
- ADD_MESSAGE - Static variable in class org.hornetq.core.persistence.impl.journal.JournalRecordIds
-
- ADD_REF - Static variable in class org.hornetq.core.persistence.impl.journal.JournalRecordIds
-
- addAddressSettings(String, String, String, long, boolean, int, long, int, int, long, double, long, long, boolean, String, long, long, String) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- addAsFailureListenerOf(CoreRemotingConnection) - Method in class org.hornetq.core.server.impl.QuorumManager
-
- addBinding(Binding) - Method in interface org.hornetq.core.postoffice.AddressManager
-
- addBinding(Binding) - Method in interface org.hornetq.core.postoffice.Bindings
-
- addBinding(Binding) - Method in class org.hornetq.core.postoffice.impl.BindingsImpl
-
- addBinding(Binding) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- addBinding(Binding) - Method in class org.hornetq.core.postoffice.impl.SimpleAddressManager
-
- addBinding(Binding) - Method in class org.hornetq.core.postoffice.impl.WildcardAddressManager
-
If the address to add the binding to contains a wildcard then a copy of the binding (with the same underlying queue)
will be added to the actual mappings.
- addBinding(Binding) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- addBytes(byte[]) - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl
-
- addBytes(byte[]) - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageInSync
-
- addBytes(byte[]) - Method in interface org.hornetq.core.replication.ReplicatedLargeMessage
-
- addBytes(byte[]) - Method in interface org.hornetq.core.server.LargeServerMessage
-
- addBytesToLargeMessage(SequentialFile, long, byte[]) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- addBytesToLargeMessage(SequentialFile, long, byte[]) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- addBytesToLargeMessage(SequentialFile, long, byte[]) - Method in interface org.hornetq.core.persistence.StorageManager
-
- addChannelHandlers(ChannelPipeline) - Method in interface org.hornetq.spi.core.protocol.ProtocolManager
-
- addClusterTopologyListener(ClusterTopologyListener) - Method in interface org.hornetq.core.server.cluster.ClusterConnection
-
- addClusterTopologyListener(ClusterTopologyListener) - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- addConnector(TransportConfiguration) - Method in interface org.hornetq.core.server.cluster.BroadcastGroup
-
- addConnector(TransportConfiguration) - Method in class org.hornetq.core.server.cluster.impl.BroadcastGroupImpl
-
- addConsumer(SimpleString) - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- addConsumer(SimpleString) - Method in interface org.hornetq.core.server.cluster.RemoteQueueBinding
-
- addConsumer(Consumer) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- addConsumer(Consumer) - Method in interface org.hornetq.core.server.Queue
-
- addGroupBinding(GroupBinding) - Method in interface org.hornetq.core.server.group.GroupingHandler
-
- addGroupBinding(GroupBinding) - Method in class org.hornetq.core.server.group.impl.LocalGroupingHandler
-
- addGroupBinding(GroupBinding) - Method in class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- addGrouping(GroupBinding) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- addGrouping(GroupBinding) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- addGrouping(GroupBinding) - Method in interface org.hornetq.core.persistence.StorageManager
-
- addHead(MessageReference) - Method in class org.hornetq.core.server.impl.LastValueQueue
-
- addHead(MessageReference) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- addHead(List<MessageReference>) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- addHead(MessageReference) - Method in interface org.hornetq.core.server.Queue
-
- addHead(List<MessageReference>) - Method in interface org.hornetq.core.server.Queue
-
- addInc(long, int) - Method in class org.hornetq.core.paging.cursor.impl.PageSubscriptionCounterImpl
-
- addInc(long, int) - Method in interface org.hornetq.core.paging.cursor.PageSubscriptionCounter
-
- addIncomingInterceptor(Interceptor) - Method in class org.hornetq.core.remoting.server.impl.RemotingServiceImpl
-
- addIncomingInterceptor(Interceptor) - Method in interface org.hornetq.core.remoting.server.RemotingService
-
- addingProtocolSupport(String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- addInPlace(long, MessageReference, boolean) - Method in class org.hornetq.core.server.impl.ScheduledDeliveryHandlerImpl
-
- addLinkedAddress(Address) - Method in interface org.hornetq.core.postoffice.Address
-
- addLinkedAddress(Address) - Method in class org.hornetq.core.postoffice.impl.AddressImpl
-
- addListener(UnproposalListener) - Method in interface org.hornetq.core.server.group.GroupingHandler
-
- addListener(UnproposalListener) - Method in class org.hornetq.core.server.group.impl.GroupHandlingAbstract
-
- addLiveMessage(PagedMessage) - Method in class org.hornetq.core.paging.cursor.impl.LivePageCacheImpl
-
- addLiveMessage(PagedMessage) - Method in interface org.hornetq.core.paging.cursor.LivePageCache
-
- addMappingInternal(SimpleString, Binding) - Method in class org.hornetq.core.postoffice.impl.SimpleAddressManager
-
- addMatch(String, T) - Method in interface org.hornetq.core.settings.HierarchicalRepository
-
Add a new match to the repository
- addMatch(String, T, boolean) - Method in interface org.hornetq.core.settings.HierarchicalRepository
-
- addMatch(String, T) - Method in class org.hornetq.core.settings.impl.HierarchicalObjectRepository
-
- addMatch(String, T, boolean) - Method in class org.hornetq.core.settings.impl.HierarchicalObjectRepository
-
Add a new match to the repository
- AddMessageRecord - Class in org.hornetq.core.persistence.impl.journal
-
- AddMessageRecord(ServerMessage) - Constructor for class org.hornetq.core.persistence.impl.journal.AddMessageRecord
-
- addMetaData(String, String) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- addMetaData(String, String) - Method in interface org.hornetq.core.server.ServerSession
-
- addNotificationListener(NotificationListener, NotificationFilter, Object) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- addNotificationListener(NotificationListener) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- addOperation(TransactionOperation) - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- addOperation(TransactionOperation) - Method in interface org.hornetq.core.transaction.Transaction
-
- addOutgoingInterceptor(Interceptor) - Method in class org.hornetq.core.remoting.server.impl.RemotingServiceImpl
-
- addOutgoingInterceptor(Interceptor) - Method in interface org.hornetq.core.remoting.server.RemotingService
-
- addPageCache(PageCache) - Method in class org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl
-
- addPageCache(PageCache) - Method in interface org.hornetq.core.paging.cursor.PageCursorProvider
-
- addPendingCounter(PageSubscriptionCounter) - Method in class org.hornetq.core.paging.impl.Page
-
This will indicate a page that will need to be called on cleanup when the page has been closed and confirmed
- addPendingDelivery(PagePosition) - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- addProtocolManagerFactory(ProtocolManagerFactory) - Method in interface org.hornetq.core.server.HornetQServer
-
- addProtocolManagerFactory(ProtocolManagerFactory) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- addQueue(SimpleString, Queue) - Method in class org.hornetq.core.server.impl.RoutingContextImpl
-
- addQueue(SimpleString, Queue) - Method in interface org.hornetq.core.server.RoutingContext
-
- addQueueBinding(long, Binding) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- addQueueBinding(long, Binding) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- addQueueBinding(long, Binding) - Method in interface org.hornetq.core.persistence.StorageManager
-
- addReadyListener(ReadyListener) - Method in class org.hornetq.core.protocol.core.impl.CoreSessionCallback
-
- addReadyListener(ReadyListener) - Method in class org.hornetq.core.remoting.impl.invm.InVMConnection
-
- addReadyListener(ReadyListener) - Method in interface org.hornetq.spi.core.protocol.SessionCallback
-
- addRedistributor(long) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- addRedistributor(long) - Method in interface org.hornetq.core.server.Queue
-
- address - Variable in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PersistentQueueBindingEncoding
-
- Address - Interface in org.hornetq.core.postoffice
-
USed to hold a hierarchical style address, delimited by a '.'.
- address - Variable in class org.hornetq.core.server.group.impl.GroupHandlingAbstract
-
- ADDRESS_FULL_MESSAGE_POLICY_TYPE - Static variable in class org.hornetq.core.config.impl.Validators
-
- ADDRESS_SETTING_RECORD - Static variable in class org.hornetq.core.persistence.impl.journal.JournalRecordIds
-
- AddressControlImpl - Class in org.hornetq.core.management.impl
-
- AddressControlImpl(SimpleString, PostOffice, PagingManager, StorageManager, HierarchicalRepository<Set<Role>>) - Constructor for class org.hornetq.core.management.impl.AddressControlImpl
-
- AddressImpl - Class in org.hornetq.core.postoffice.impl
-
splits an address string into its hierarchical parts split by '.'
- AddressImpl(SimpleString) - Constructor for class org.hornetq.core.postoffice.impl.AddressImpl
-
- addressIsFull(String) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- addressIsNull() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- AddressManager - Interface in org.hornetq.core.postoffice
-
Used to maintain addresses and BindingsImpl.
- AddressSettings - Class in org.hornetq.core.settings.impl
-
Configuration settings that are applied on the address level
- AddressSettings(AddressSettings) - Constructor for class org.hornetq.core.settings.impl.AddressSettings
-
- AddressSettings() - Constructor for class org.hornetq.core.settings.impl.AddressSettings
-
- AddressSettingsDeployer - Class in org.hornetq.core.deployers.impl
-
A deployer for creating a set of queue settings and adding them to a repository
- AddressSettingsDeployer(DeploymentManager, HierarchicalRepository<AddressSettings>) - Constructor for class org.hornetq.core.deployers.impl.AddressSettingsDeployer
-
- addressSettingsRepository - Variable in class org.hornetq.core.server.impl.QueueFactoryImpl
-
- addRole(String, String) - Method in interface org.hornetq.spi.core.security.HornetQSecurityManager
-
adds a new role for a user.
- addRole(String, String) - Method in class org.hornetq.spi.core.security.HornetQSecurityManagerImpl
-
- addRole(String, String) - Method in class org.hornetq.spi.core.security.JAASSecurityManager
-
- addSecuritySettings(String, String, String, String, String, String, String, String) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- addSize(int) - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- addSize(int) - Method in interface org.hornetq.core.paging.PagingStore
-
- addTail(MessageReference, boolean) - Method in class org.hornetq.core.server.impl.LastValueQueue
-
- addTail(MessageReference) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- addTail(MessageReference, boolean) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- addTail(MessageReference) - Method in interface org.hornetq.core.server.Queue
-
- addTail(MessageReference, boolean) - Method in interface org.hornetq.core.server.Queue
-
- addToCache(byte[], Transaction) - Method in interface org.hornetq.core.postoffice.DuplicateIDCache
-
- addToCache(byte[], Transaction) - Method in class org.hornetq.core.postoffice.impl.DuplicateIDCacheImpl
-
- addToConfiguration(URI, String, Node) - Method in class org.hornetq.core.deployers.impl.XmlDeployer
-
adds a URL to the already configured set of url's this deployer is handling
- addToPage(PagingStore, ServerMessage, Transaction, RouteContextList) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- addToPage(PagingStore, ServerMessage, Transaction, RouteContextList) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- addToPage(PagingStore, ServerMessage, Transaction, RouteContextList) - Method in interface org.hornetq.core.persistence.StorageManager
-
Write message to page if we are paging.
- addTransaction(PageTransactionInfo) - Method in class org.hornetq.core.paging.impl.PagingManagerImpl
-
- addTransaction(PageTransactionInfo) - Method in interface org.hornetq.core.paging.PagingManager
-
Point to inform/restoring Transactions used when the messages were added into paging
- addUniqueMetaData(String, String) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- addUniqueMetaData(String, String) - Method in interface org.hornetq.core.server.ServerSession
-
- addUser(String, String) - Method in interface org.hornetq.spi.core.security.HornetQSecurityManager
-
adds a new user
- addUser(String, String) - Method in class org.hornetq.spi.core.security.HornetQSecurityManagerImpl
-
- addUser(String, String) - Method in class org.hornetq.spi.core.security.JAASSecurityManager
-
- afterCommit(Transaction) - Method in class org.hornetq.core.server.impl.QueueImpl.RefsOperation
-
- afterCommit(Transaction) - Method in interface org.hornetq.core.transaction.TransactionOperation
-
After commit shouldn't throw any exception.
- afterCommit(Transaction) - Method in class org.hornetq.core.transaction.TransactionOperationAbstract
-
After commit shouldn't throw any exception.
- afterCompleteOperations(IOAsyncTask) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- afterCompleteOperations(IOAsyncTask) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- afterCompleteOperations(IOAsyncTask) - Method in interface org.hornetq.core.persistence.StorageManager
-
- afterConnect() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- afterConnect() - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionBridge
-
- afterPageRead() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- afterPageRead() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- afterPageRead() - Method in interface org.hornetq.core.persistence.StorageManager
-
We need a safeguard in place to avoid too much concurrent IO happening on Paging, otherwise
the system may become unresponsive if too many destinations are reading all the same time.
- afterPrepare(Transaction) - Method in interface org.hornetq.core.transaction.TransactionOperation
-
After prepare shouldn't throw any exception.
- afterPrepare(Transaction) - Method in class org.hornetq.core.transaction.TransactionOperationAbstract
-
After prepare shouldn't throw any exception.
- afterRollback(Transaction) - Method in class org.hornetq.core.server.impl.QueueImpl.RefsOperation
-
- afterRollback(Transaction) - Method in interface org.hornetq.core.transaction.TransactionOperation
-
After rollback shouldn't throw any exception.
- afterRollback(Transaction) - Method in class org.hornetq.core.transaction.TransactionOperationAbstract
-
After rollback shouldn't throw any exception.
- AIOFileLockNodeManager - Class in org.hornetq.core.server.impl
-
This is using the HornetQ Libaio Native to perform calls to flock on a Linux system.
- AIOFileLockNodeManager(String, boolean) - Constructor for class org.hornetq.core.server.impl.AIOFileLockNodeManager
-
- AIONotFound() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- allocateDirectBuffer(int) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- allocateDirectBuffer(int) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- allocateDirectBuffer(int) - Method in interface org.hornetq.core.persistence.StorageManager
-
AIO has an optimized buffer which has a method to release it
instead of the way NIO will release data based on GC.
- ALLOWABLE_ACCEPTOR_KEYS - Static variable in class org.hornetq.core.remoting.impl.invm.TransportConstants
-
- ALLOWABLE_CONNECTOR_KEYS - Static variable in class org.hornetq.core.remoting.impl.invm.TransportConstants
-
- allowInvmSecurityOverride(HornetQPrincipal) - Method in class org.hornetq.core.remoting.server.impl.RemotingServiceImpl
-
- allowInvmSecurityOverride(HornetQPrincipal) - Method in interface org.hornetq.core.remoting.server.RemotingService
-
Allow acceptors to use this as their default security Principal if applicable.
- alreadyHaveReplicationServer() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- announceBackup() - Method in class org.hornetq.core.server.cluster.BackupManager
-
- announceBackupNoClusterConnections() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- announceBackupNoConnector(String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- announceReplicatingBackupToLive(Channel, boolean) - Method in class org.hornetq.core.server.cluster.ClusterManager
-
XXX HORNETQ-720
- AnyLiveNodeLocator - Class in org.hornetq.core.server.impl
-
This implementation looks for any available live node, once tried with no success it is marked as
tried and the next available is used.
- AnyLiveNodeLocator(QuorumManager, HornetQServerImpl) - Constructor for class org.hornetq.core.server.impl.AnyLiveNodeLocator
-
- appendAddRecord(long, byte, byte[], boolean) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendAddRecord(long, byte, EncodingSupport, boolean) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendAddRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendAddRecordTransactional(long, long, byte, byte[]) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendAddRecordTransactional(long, long, byte, EncodingSupport) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendAddRecordTransactional(byte, ReplicationManager.ADD_OPERATION_TYPE, long, long, byte, EncodingSupport) - Method in class org.hornetq.core.replication.ReplicationManager
-
- appendCommitRecord(long, boolean) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendCommitRecord(long, boolean, IOCompletion) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendCommitRecord(long, boolean, IOCompletion, boolean) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendCommitRecord(byte, long, boolean, boolean) - Method in class org.hornetq.core.replication.ReplicationManager
-
- appendDeleteRecord(long, boolean) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendDeleteRecord(long, boolean, IOCompletion) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendDeleteRecord(byte, long) - Method in class org.hornetq.core.replication.ReplicationManager
-
- appendDeleteRecordTransactional(long, long, byte[]) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendDeleteRecordTransactional(long, long, EncodingSupport) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendDeleteRecordTransactional(long, long) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendDeleteRecordTransactional(byte, long, long, EncodingSupport) - Method in class org.hornetq.core.replication.ReplicationManager
-
- appendDeleteRecordTransactional(byte, long, long) - Method in class org.hornetq.core.replication.ReplicationManager
-
- appendPrepareRecord(long, byte[], boolean) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendPrepareRecord(long, EncodingSupport, boolean) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendPrepareRecord(long, EncodingSupport, boolean, IOCompletion) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendPrepareRecord(byte, long, EncodingSupport) - Method in class org.hornetq.core.replication.ReplicationManager
-
- appendRollbackRecord(long, boolean) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendRollbackRecord(long, boolean, IOCompletion) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendRollbackRecord(byte, long) - Method in class org.hornetq.core.replication.ReplicationManager
-
- appendUpdateRecord(long, byte, byte[], boolean) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendUpdateRecord(long, byte, EncodingSupport, boolean) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendUpdateRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendUpdateRecord(byte, ReplicationManager.ADD_OPERATION_TYPE, long, byte, EncodingSupport) - Method in class org.hornetq.core.replication.ReplicationManager
-
- appendUpdateRecordTransactional(long, long, byte, byte[]) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- appendUpdateRecordTransactional(long, long, byte, EncodingSupport) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- applyIncrementOnTX(Transaction, long, int) - Method in class org.hornetq.core.paging.cursor.impl.PageSubscriptionCounterImpl
-
This method will install the TXs
- applyIncrementOnTX(Transaction, long, int) - Method in interface org.hornetq.core.paging.cursor.PageSubscriptionCounter
-
- applySetting(AddressSettings) - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- applySetting(AddressSettings) - Method in interface org.hornetq.core.paging.PagingStore
-
- asyncConnectionExecutionEnabled - Variable in class org.hornetq.core.config.impl.ConfigurationImpl
-
- authenticate(String, String) - Method in class org.hornetq.core.security.impl.SecurityStoreImpl
-
- authenticate(String, String) - Method in interface org.hornetq.core.security.SecurityStore
-
- autoConvertError(Class<? extends Object>) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- autoFailBackDenied() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- awaitBindings() - Method in interface org.hornetq.core.server.group.GroupingHandler
-
- awaitBindings() - Method in class org.hornetq.core.server.group.impl.LocalGroupingHandler
-
- awaitBindings() - Method in class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- awaitFailBack() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- awaitingLiveLock() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- awaitLiveNode() - Method in class org.hornetq.core.server.impl.FileLockNodeManager
-
- awaitLiveNode() - Method in class org.hornetq.core.server.NodeManager
-
- GE_ZERO - Static variable in class org.hornetq.core.config.impl.Validators
-
- generateID() - Method in class org.hornetq.core.persistence.impl.journal.BatchingIDGenerator
-
- generateUniqueID() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- generateUniqueID() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- generateUniqueID() - Method in interface org.hornetq.core.persistence.StorageManager
-
- generatingThreadDump(String) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- GENERIC_IGNORED_FILTER - Static variable in class org.hornetq.core.server.impl.HornetQServerImpl
-
JMS Topics (which are outside of the scope of the core API) will require a dumb subscription
with a dummy-filter at this current version as a way to keep its existence valid and TCK
tests.
- getAcceptor() - Method in class org.hornetq.core.remoting.impl.invm.InVMConnector
-
- getAcceptor(int) - Method in class org.hornetq.core.remoting.impl.invm.InVMRegistry
-
- getAcceptor(String) - Method in class org.hornetq.core.remoting.server.impl.RemotingServiceImpl
-
- getAcceptor(String) - Method in interface org.hornetq.core.remoting.server.RemotingService
-
Returns the acceptor identified by its name
or null
if it does not exists.
- getAcceptorConfigurations() - Method in interface org.hornetq.core.config.Configuration
-
Returns the acceptors configured for this server.
- getAcceptorConfigurations() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getActiveTokens() - Method in class org.hornetq.core.replication.ReplicationManager
-
A list of tokens that are still waiting for replications to be completed
- getAddress() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getAddress() - Method in class org.hornetq.core.config.CoreQueueConfiguration
-
- getAddress() - Method in class org.hornetq.core.config.DivertConfiguration
-
- getAddress() - Method in class org.hornetq.core.management.impl.AddressControlImpl
-
- getAddress() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- getAddress() - Method in class org.hornetq.core.management.impl.DivertControlImpl
-
- getAddress() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- getAddress() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getAddress() - Method in interface org.hornetq.core.paging.PagingStore
-
- getAddress() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PersistentQueueBindingEncoding
-
- getAddress() - Method in interface org.hornetq.core.persistence.QueueBindingInfo
-
- getAddress() - Method in interface org.hornetq.core.postoffice.Address
-
- getAddress() - Method in interface org.hornetq.core.postoffice.Binding
-
- getAddress() - Method in class org.hornetq.core.postoffice.impl.AddressImpl
-
- getAddress() - Method in class org.hornetq.core.postoffice.impl.DivertBinding
-
- getAddress() - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- getAddress() - Method in class org.hornetq.core.postoffice.QueueInfo
-
- getAddress() - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- getAddress() - Method in interface org.hornetq.core.server.cluster.MessageFlowRecord
-
- getAddress() - Method in class org.hornetq.core.server.group.impl.GroupingHandlerConfiguration
-
- getAddress() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getAddress() - Method in interface org.hornetq.core.server.Queue
-
- getAddressesSettings() - Method in interface org.hornetq.core.config.Configuration
-
- getAddressesSettings() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getAddressFullMessagePolicy() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getAddressFullMessagePolicy() - Method in interface org.hornetq.core.paging.PagingStore
-
- getAddressFullMessagePolicy() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getAddressManager() - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- getAddressMatch() - Method in class org.hornetq.core.persistence.config.PersistedAddressSetting
-
- getAddressMatch() - Method in class org.hornetq.core.persistence.config.PersistedRoles
-
- getAddressNames() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getAddressParts() - Method in interface org.hornetq.core.postoffice.Address
-
- getAddressParts() - Method in class org.hornetq.core.postoffice.impl.AddressImpl
-
- getAddressSettingsAsJSON(String) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getAddressSettingsRepository() - Method in interface org.hornetq.core.server.HornetQServer
-
- getAddressSettingsRepository() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getAddressSize() - Method in class org.hornetq.core.management.impl.AddressControlImpl
-
- getAddressSize() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getAddressSize() - Method in interface org.hornetq.core.paging.PagingStore
-
- getAlignment() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- getAllOperations() - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- getAllOperations() - Method in interface org.hornetq.core.transaction.Transaction
-
- getAllowableProperties() - Method in class org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory
-
- getAllowableProperties() - Method in class org.hornetq.core.remoting.impl.invm.InVMConnectorFactory
-
- getAllowableProperties() - Method in class org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory
-
- getAllowableProperties() - Method in interface org.hornetq.core.server.ConnectorServiceFactory
-
- getAllowableProperties() - Method in interface org.hornetq.spi.core.remoting.AcceptorFactory
-
Returns the allowable properties for this acceptor.
- getAlternativeClusterName() - Method in class org.hornetq.core.server.group.impl.Response
-
- getAttribute(String, String) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- getAttributeValue(Node, String) - Static method in class org.hornetq.utils.XMLConfigurationUtil
-
- getAvailableCredits() - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
To be used on tests only
- getBackupGroupName() - Method in interface org.hornetq.core.config.Configuration
-
returns the name used to group of live/backup servers
- getBackupGroupName() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getBackupManager() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getBackupServerConfigurations() - Method in interface org.hornetq.core.config.Configuration
-
- getBackupServerConfigurations() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getBackupTransportConnection() - Method in class org.hornetq.core.replication.ReplicationManager
-
Used while stopping the server to ensure that we freeze communications with the backup.
- getBatchingBufferSize() - Method in class org.hornetq.core.remoting.impl.invm.InVMConnection
-
- getBindable() - Method in interface org.hornetq.core.postoffice.Binding
-
- getBindable() - Method in class org.hornetq.core.postoffice.impl.DivertBinding
-
- getBindable() - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- getBindable() - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- getBinding(SimpleString) - Method in interface org.hornetq.core.postoffice.AddressManager
-
- getBinding(SimpleString) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- getBinding(SimpleString) - Method in class org.hornetq.core.postoffice.impl.SimpleAddressManager
-
- getBinding(SimpleString) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- getBindingNames() - Method in class org.hornetq.core.management.impl.AddressControlImpl
-
- getBindings() - Method in interface org.hornetq.core.postoffice.AddressManager
-
- getBindings() - Method in interface org.hornetq.core.postoffice.Bindings
-
- getBindings() - Method in class org.hornetq.core.postoffice.impl.BindingsImpl
-
- getBindings() - Method in class org.hornetq.core.postoffice.impl.SimpleAddressManager
-
- getBindingsDirectory() - Method in interface org.hornetq.core.config.Configuration
-
Returns the file system directory used to store bindings.
- getBindingsDirectory() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getBindingsDirectory() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getBindingsForAddress(SimpleString) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- getBindingsForAddress(SimpleString) - Method in interface org.hornetq.core.postoffice.PostOffice
-
Differently to lookupBindings, this will always create a new element on the Queue if non-existent
- getBindingsForRoutingAddress(SimpleString) - Method in interface org.hornetq.core.postoffice.AddressManager
-
- getBindingsForRoutingAddress(SimpleString) - Method in class org.hornetq.core.postoffice.impl.SimpleAddressManager
-
- getBindingsForRoutingAddress(SimpleString) - Method in class org.hornetq.core.postoffice.impl.WildcardAddressManager
-
- getBindingsJournal() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- getBindingsJournal() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- getBindingsJournal() - Method in interface org.hornetq.core.persistence.StorageManager
-
- getBody() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageWriteMessage
-
- getBodyEncoder() - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl
-
- getBodyInputStream() - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- getBoolean(Element, String, boolean) - Static method in class org.hornetq.utils.XMLConfigurationUtil
-
- getBridge() - Method in interface org.hornetq.core.server.cluster.MessageFlowRecord
-
- getBridgeConfigurations() - Method in interface org.hornetq.core.config.Configuration
-
Returns the bridges configured for this server.
- getBridgeConfigurations() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getBridgeNames() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getBridges() - Method in class org.hornetq.core.server.cluster.ClusterManager
-
- getBroadcastGroupConfigurations() - Method in interface org.hornetq.core.config.Configuration
-
Returns the broadcast groups configured for this server.
- getBroadcastGroupConfigurations() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getBroadcastGroups() - Method in class org.hornetq.core.server.cluster.ClusterManager
-
- getBroadcastPeriod() - Method in class org.hornetq.core.management.impl.BroadcastGroupControlImpl
-
- getCacheSize() - Method in class org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl
-
- getCacheSize() - Method in interface org.hornetq.core.paging.cursor.PageCursorProvider
-
- getCacheSize() - Method in interface org.hornetq.core.settings.HierarchicalRepository
-
- getCacheSize() - Method in class org.hornetq.core.settings.impl.HierarchicalObjectRepository
-
- getCallFailoverTimeout() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getCallTimeout() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getCallTimeout() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getChannel() - Method in class org.hornetq.core.protocol.core.ServerSessionPacketHandler
-
- getChannel() - Method in class org.hornetq.core.replication.ReplicationEndpoint
-
- getChosenClusterName() - Method in class org.hornetq.core.server.group.impl.Response
-
- getClientFailureCheckPeriod() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getClientFailureCheckPeriod() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getClusterConfigurations() - Method in interface org.hornetq.core.config.Configuration
-
Returns the cluster connections configured for this server.
- getClusterConfigurations() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getClusterConnection() - Method in class org.hornetq.core.remoting.impl.invm.InVMAcceptor
-
- getClusterConnection() - Method in class org.hornetq.core.remoting.impl.netty.NettyAcceptor
-
- getClusterConnection(String) - Method in class org.hornetq.core.server.cluster.ClusterManager
-
- getClusterConnection() - Method in interface org.hornetq.spi.core.remoting.Acceptor
-
- getClusterConnections() - Method in class org.hornetq.core.server.cluster.ClusterManager
-
- getClusterManager() - Method in interface org.hornetq.core.server.HornetQServer
-
- getClusterManager() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getClusterName() - Method in interface org.hornetq.core.persistence.GroupingInfo
-
- getClusterName() - Method in interface org.hornetq.core.postoffice.Binding
-
- getClusterName() - Method in class org.hornetq.core.postoffice.impl.DivertBinding
-
- getClusterName() - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- getClusterName() - Method in class org.hornetq.core.postoffice.QueueInfo
-
- getClusterName() - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- getClusterName() - Method in class org.hornetq.core.server.group.impl.GroupBinding
-
- getClusterName() - Method in class org.hornetq.core.server.group.impl.Proposal
-
- getClusterName() - Method in class org.hornetq.core.server.group.impl.Response
-
- getClusterNotificationAttempts() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getClusterNotificationInterval() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getClusterPassword() - Method in interface org.hornetq.core.config.Configuration
-
Returns the cluster password for this server.
- getClusterPassword() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getClusterPassword() - Method in class org.hornetq.core.protocol.core.impl.wireformat.BackupRegistrationMessage
-
- getClusterUser() - Method in interface org.hornetq.core.config.Configuration
-
Returns the cluster user for this server.
- getClusterUser() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getClusterUser() - Method in class org.hornetq.core.protocol.core.impl.wireformat.BackupRegistrationMessage
-
- getConfigFileNames() - Method in interface org.hornetq.core.deployers.Deployer
-
The name of the configuration files to look for for deployment
- getConfigFileNames() - Method in class org.hornetq.core.deployers.impl.XmlDeployer
-
- getConfiguration() - Method in class org.hornetq.core.remoting.impl.invm.InVMAcceptor
-
- getConfiguration() - Method in class org.hornetq.core.remoting.impl.netty.NettyAcceptor
-
- getConfiguration() - Method in interface org.hornetq.core.server.HornetQServer
-
- getConfiguration() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getConfiguration() - Method in interface org.hornetq.spi.core.remoting.Acceptor
-
- getConfigurationUrl() - Method in class org.hornetq.core.config.impl.FileConfiguration
-
- getConfirmationWindowSize() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getConfirmationWindowSize() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getConnectionCount() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getConnectionCount() - Method in interface org.hornetq.core.server.HornetQServer
-
- getConnectionCount() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getConnectionID() - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- getConnectionID() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getConnectionID() - Method in interface org.hornetq.core.server.ServerConsumer
-
- getConnectionID() - Method in interface org.hornetq.core.server.ServerSession
-
- getConnections() - Method in class org.hornetq.core.remoting.server.impl.RemotingServiceImpl
-
- getConnections() - Method in interface org.hornetq.core.remoting.server.RemotingService
-
- getConnectionTTL() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getConnectionTTL() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getConnectionTTLOverride() - Method in interface org.hornetq.core.config.Configuration
-
Returns the connection time to live.
- getConnectionTTLOverride() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getConnectionTTLOverride() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getConnector() - Method in class org.hornetq.core.protocol.core.impl.wireformat.BackupRegistrationMessage
-
- getConnector() - Method in interface org.hornetq.core.server.cluster.ClusterConnection
-
- getConnector() - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- getConnectorConfig() - Method in class org.hornetq.core.remoting.impl.invm.InVMConnection
-
- getConnectorConfigurations() - Method in interface org.hornetq.core.config.Configuration
-
Returns the connectors configured for this server.
- getConnectorConfigurations() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getConnectorName() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getConnectorName() - Method in class org.hornetq.core.config.ConnectorServiceConfiguration
-
- getConnectorPairs() - Method in class org.hornetq.core.management.impl.BroadcastGroupControlImpl
-
- getConnectorPairsAsJSON() - Method in class org.hornetq.core.management.impl.BroadcastGroupControlImpl
-
- getConnectors() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getConnectors() - Method in class org.hornetq.core.server.impl.ConnectorsService
-
- getConnectorsAsJSON() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getConnectorServiceConfigurations() - Method in interface org.hornetq.core.config.Configuration
-
- getConnectorServiceConfigurations() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getConnectorsService() - Method in interface org.hornetq.core.server.HornetQServer
-
- getConnectorsService() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getConsumerCount() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- getConsumerCount() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getConsumerCount() - Method in interface org.hornetq.core.server.Queue
-
- getConsumerId() - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- getConsumerId() - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- getConsumerId() - Method in interface org.hornetq.core.server.MessageReference
-
- getConsumeRoles() - Method in class org.hornetq.core.persistence.config.PersistedRoles
-
- getConsumers() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getConsumers() - Method in interface org.hornetq.core.server.Queue
-
- getConsumersRefCount() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getConsumersRefCount() - Method in interface org.hornetq.core.server.Queue
-
- getContexListing() - Method in class org.hornetq.core.server.impl.RoutingContextImpl
-
- getContexListing() - Method in interface org.hornetq.core.server.RoutingContext
-
- getContext() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- getContext() - Static method in class org.hornetq.core.persistence.impl.journal.OperationContextImpl
-
- getContext(ExecutorFactory) - Static method in class org.hornetq.core.persistence.impl.journal.OperationContextImpl
-
- getContext() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- getContext() - Method in interface org.hornetq.core.persistence.StorageManager
-
Get the context associated with the thread for later reuse
- getContext() - Method in class org.hornetq.core.registry.JndiBindingRegistry
-
- getContext() - Method in class org.hornetq.core.registry.MapBindingRegistry
-
- getContext() - Method in interface org.hornetq.spi.core.naming.BindingRegistry
-
The context used by the registry.
- getContextListing(SimpleString) - Method in class org.hornetq.core.server.impl.RoutingContextImpl
-
- getContextListing(SimpleString) - Method in interface org.hornetq.core.server.RoutingContext
-
- getCount() - Method in class org.hornetq.api.core.management.MessageCounterInfo
-
Returns the number of messages added to the queue since it was created.
- getCount() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
Gets the total message count since startup or
last counter reset
- getCountDelta() - Method in class org.hornetq.api.core.management.MessageCounterInfo
-
Returns the number of messages added to the queue since the last counter sample.
- getCountDelta() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
Gets the message count delta since last method call
- getCounter() - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- getCounters() - Method in class org.hornetq.core.messagecounter.MessageCounter.DayCounter
-
- getCreateDurableQueueRoles() - Method in class org.hornetq.core.persistence.config.PersistedRoles
-
- getCreateNonDurableQueueRoles() - Method in class org.hornetq.core.persistence.config.PersistedRoles
-
- getCreateTime() - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- getCreateTime() - Method in interface org.hornetq.core.transaction.Transaction
-
- getCreationTime() - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- getCreationTime() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getCreationTime() - Method in interface org.hornetq.core.server.ServerConsumer
-
- getCreationTime() - Method in interface org.hornetq.core.server.ServerSession
-
- getCurrentID() - Method in class org.hornetq.core.persistence.impl.journal.BatchingIDGenerator
-
- getCurrentIds() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getCurrentIds() - Method in interface org.hornetq.core.paging.PagingStore
-
Files to synchronize with a remote backup.
- getCurrentPage() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getCurrentPage() - Method in interface org.hornetq.core.paging.PagingStore
-
- getCurrentTransaction() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getCurrentTransaction() - Method in interface org.hornetq.core.server.ServerSession
-
- getCurrentUniqueID() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- getCurrentUniqueID() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- getCurrentUniqueID() - Method in interface org.hornetq.core.persistence.StorageManager
-
- getCurrentWritingPage() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getCurrentWritingPage() - Method in interface org.hornetq.core.paging.PagingStore
-
Returns the page id of the current page in which the system is writing files.
- getCursorProvider() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getCursorProvider() - Method in interface org.hornetq.core.paging.PagingStore
-
- getData() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationSyncFileMessage
-
- getDataFiles() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- getDataType() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage
-
- getDataType(byte) - Static method in enum org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage.SyncDataType
-
- getDate() - Method in class org.hornetq.core.messagecounter.MessageCounter.DayCounter
-
Gets copy of day counter date
- getDeadLetterAddress() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- getDeadLetterAddress() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getDefaultConfigFileNames() - Method in class org.hornetq.core.deployers.impl.AddressSettingsDeployer
-
- getDefaultConfigFileNames() - Method in class org.hornetq.core.deployers.impl.BasicUserCredentialsDeployer
-
- getDefaultConfigFileNames() - Method in class org.hornetq.core.deployers.impl.QueueDeployer
-
The name of the configuration file name to look for for deployment
- getDefaultConfigFileNames() - Method in class org.hornetq.core.deployers.impl.SecurityDeployer
-
The name of the configuration file name to look for for deployment
- getDefaultConfigFileNames() - Method in class org.hornetq.core.deployers.impl.XmlDeployer
-
- getDefaultConnection(TransportConfiguration) - Method in class org.hornetq.core.server.cluster.ClusterManager
-
Return the default ClusterConnection to be used case it's not defined by the acceptor
- getDefaultHornetQPrincipal() - Method in class org.hornetq.core.remoting.impl.invm.InVMConnection
-
- getDeleteDurableQueueRoles() - Method in class org.hornetq.core.persistence.config.PersistedRoles
-
- getDeleteNonDurableQueueRoles() - Method in class org.hornetq.core.persistence.config.PersistedRoles
-
- getDeliveringCount() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- getDeliveringCount() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getDeliveringCount() - Method in interface org.hornetq.core.server.Queue
-
- getDeliveringMessages() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- getDeliveringMessages() - Method in class org.hornetq.core.server.cluster.impl.Redistributor
-
- getDeliveringMessages() - Method in interface org.hornetq.core.server.Consumer
-
Add the in-deliver mode messages to the ref-list passed as parameter
- getDeliveringMessages() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getDeliveringMessages() - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- getDeliveringMessages() - Method in interface org.hornetq.core.server.Queue
-
Return a Map consisting of consumer.toString and its messages
Delivering message is a property of the consumer, this method will aggregate the results per Server's consumer object
- getDeliveryCount() - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- getDeliveryCount() - Method in class org.hornetq.core.persistence.impl.journal.AddMessageRecord
-
- getDeliveryCount() - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- getDeliveryCount() - Method in interface org.hornetq.core.server.MessageReference
-
- getDeployed() - Method in class org.hornetq.core.deployers.impl.FileDeploymentManager
-
- getDeployers() - Method in class org.hornetq.core.deployers.impl.FileDeploymentManager
-
- getDeploymentManager() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getDepth() - Method in class org.hornetq.api.core.management.MessageCounterInfo
-
Returns the number of messages currently in the queue.
- getDepthDelta() - Method in class org.hornetq.api.core.management.MessageCounterInfo
-
Returns the number of messages in the queue since last counter sample.
- getDestinationName() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
- getDestinationSubscription() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
- getDiscoveryGroupConfiguration(ClusterConnectionConfiguration, Configuration) - Static method in class org.hornetq.core.server.cluster.ClusterConfigurationUtil
-
- getDiscoveryGroupConfigurations() - Method in interface org.hornetq.core.config.Configuration
-
Returns the discovery groups configured for this server.
- getDiscoveryGroupConfigurations() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getDiscoveryGroupName() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getDiscoveryGroupName() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getDiscoveryGroupName() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- getDiscoveryGroupName() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- getDistance() - Method in interface org.hornetq.core.postoffice.Binding
-
- getDistance() - Method in class org.hornetq.core.postoffice.impl.DivertBinding
-
- getDistance() - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- getDistance() - Method in class org.hornetq.core.postoffice.QueueInfo
-
- getDistance() - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- getDivertConfigurations() - Method in interface org.hornetq.core.config.Configuration
-
Returns the diverts configured for this server.
- getDivertConfigurations() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getDivertNames() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getDouble(Element, String, double, Validators.Validator) - Static method in class org.hornetq.utils.XMLConfigurationUtil
-
- getDuplicateBytes(UUID, long) - Static method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- getDuplicateIDBytes() - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- getDuplicateIDBytes() - Method in interface org.hornetq.core.server.ServerMessage
-
- getDuplicateIDCache(SimpleString) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- getDuplicateIDCache(SimpleString) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- getDuplicateIDCaches() - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- getDuplicateProperty() - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- getDuplicateProperty() - Method in interface org.hornetq.core.server.ServerMessage
-
- getDurableQueues(SimpleString) - Method in class org.hornetq.core.server.impl.RoutingContextImpl
-
- getDurableQueues() - Method in interface org.hornetq.core.server.RouteContextList
-
- getDurableQueues(SimpleString) - Method in interface org.hornetq.core.server.RoutingContext
-
- getElementTagName() - Method in class org.hornetq.core.deployers.impl.AddressSettingsDeployer
-
the names of the elements to deploy
- getElementTagName() - Method in class org.hornetq.core.deployers.impl.BasicUserCredentialsDeployer
-
- getElementTagName() - Method in class org.hornetq.core.deployers.impl.QueueDeployer
-
the names of the elements to deploy
- getElementTagName() - Method in class org.hornetq.core.deployers.impl.SecurityDeployer
-
the names of the elements to deploy
- getElementTagName() - Method in class org.hornetq.core.deployers.impl.XmlDeployer
-
the names of the elements to deploy
- getEncodeSize() - Method in class org.hornetq.core.paging.impl.PagedMessageImpl
-
- getEncodeSize() - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.config.PersistedAddressSetting
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.config.PersistedRoles
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.BatchingIDGenerator.IDCounterEncoding
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.CursorAckRecordEncoding
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.DeliveryCountUpdateEncoding
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.DuplicateIDEncoding
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.HeuristicCompletionEncoding
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.LargeMessageEncoding
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PageCountPendingImpl
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PageCountRecord
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PageCountRecordInc
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PageUpdateTXEncoding
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PendingLargeMessageEncoding
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PersistentQueueBindingEncoding
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.QueueEncoding
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.ScheduledDeliveryEncoding
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.XidEncoding
-
- getEncodeSize() - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl
-
- getEncodeSize() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getExecutor() - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- getExecutor() - Method in class org.hornetq.core.remoting.impl.invm.InVMConnection
-
- getExecutor() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
The cluster manager needs to use the same executor to close the serverLocator, otherwise the stop will break.
- getExecutor() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getExecutor() - Method in interface org.hornetq.core.server.Queue
-
- getExecutorFactory() - Method in class org.hornetq.core.remoting.impl.invm.InVMAcceptor
-
- getExecutorFactory() - Method in interface org.hornetq.core.server.HornetQServer
-
- getExecutorFactory() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getExpiryAddress() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- getExpiryAddress() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getExpiryAddress() - Method in interface org.hornetq.core.server.Queue
-
- getExpiryAddress() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getExpiryDelay() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getExtension() - Method in enum org.hornetq.core.persistence.StorageManager.LargeMessageExtension
-
- getFactoryClassName() - Method in class org.hornetq.core.config.ConnectorServiceConfiguration
-
- getFactoryClassName() - Method in class org.hornetq.core.management.impl.AcceptorControlImpl
-
- getFailbackDelay() - Method in interface org.hornetq.core.config.Configuration
-
Returns the delay to wait before fail-back occurs on restart.
- getFailbackDelay() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getFile() - Method in class org.hornetq.core.paging.impl.Page
-
- getFile() - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl
-
- getFile() - Method in interface org.hornetq.core.server.LargeServerMessage
-
- getFileDeployerScanPeriod() - Method in interface org.hornetq.core.config.Configuration
-
Returns the period (in milliseconds) to scan configuration files used by deployment.
- getFileDeployerScanPeriod() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getFileFactory() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- getFileIds() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage
-
- getFileSize() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- getFileType(byte) - Static method in enum org.hornetq.core.protocol.core.impl.wireformat.ReplicationSyncFileMessage.FileType
-
- getFileType() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationSyncFileMessage
-
- getFilter() - Method in class org.hornetq.core.management.impl.DivertControlImpl
-
- getFilter() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- getFilter() - Method in interface org.hornetq.core.postoffice.Binding
-
- getFilter() - Method in class org.hornetq.core.postoffice.impl.DivertBinding
-
- getFilter() - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- getFilter() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- getFilter() - Method in class org.hornetq.core.server.cluster.impl.Redistributor
-
- getFilter() - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- getFilter() - Method in interface org.hornetq.core.server.Consumer
-
- getFilter() - Method in interface org.hornetq.core.server.Divert
-
- getFilter() - Method in class org.hornetq.core.server.impl.DivertImpl
-
- getFilter() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getFilter() - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- getFilter() - Method in interface org.hornetq.core.server.Queue
-
- getFilters() - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- getFilterString() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getFilterString() - Method in class org.hornetq.core.config.CoreQueueConfiguration
-
- getFilterString() - Method in class org.hornetq.core.config.DivertConfiguration
-
- getFilterString() - Method in interface org.hornetq.core.filter.Filter
-
- getFilterString() - Method in class org.hornetq.core.filter.impl.FilterImpl
-
- getFilterString() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- getFilterString() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PersistentQueueBindingEncoding
-
- getFilterString() - Method in interface org.hornetq.core.persistence.QueueBindingInfo
-
- getFilterString() - Method in class org.hornetq.core.postoffice.QueueInfo
-
- getFilterStrings() - Method in class org.hornetq.core.postoffice.QueueInfo
-
- getFirstMessageAsJSON() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- getFirstPage() - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- getFirstPage() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getFirstPage() - Method in interface org.hornetq.core.paging.PagingStore
-
- getFolder() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getFolder() - Method in interface org.hornetq.core.paging.PagingStore
-
- getForwardingAddress() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getForwardingAddress() - Method in class org.hornetq.core.config.DivertConfiguration
-
- getForwardingAddress() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- getForwardingAddress() - Method in class org.hornetq.core.management.impl.DivertControlImpl
-
- getForwardingAddress() - Method in interface org.hornetq.core.server.cluster.Bridge
-
- getForwardingAddress() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- getForwardingConnection() - Method in interface org.hornetq.core.server.cluster.Bridge
-
- getForwardingConnection() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- getGroupAddress() - Method in class org.hornetq.core.management.impl.BroadcastGroupControlImpl
-
- getGroupId() - Method in interface org.hornetq.core.persistence.GroupingInfo
-
- getGroupId() - Method in class org.hornetq.core.server.group.impl.GroupBinding
-
- getGroupId() - Method in class org.hornetq.core.server.group.impl.Proposal
-
- getGroupId() - Method in class org.hornetq.core.server.group.impl.Response
-
- getGroupingHandler() - Method in interface org.hornetq.core.server.HornetQServer
-
- getGroupingHandler() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getGroupingHandlerConfiguration() - Method in interface org.hornetq.core.config.Configuration
-
Returns the grouping handler configured for this server.
- getGroupingHandlerConfiguration() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getGroupPort() - Method in class org.hornetq.core.management.impl.BroadcastGroupControlImpl
-
- getGroupsUsed() - Method in class org.hornetq.core.server.impl.QueueImpl
-
For testing only
- getGroupTimeout() - Method in class org.hornetq.core.server.group.impl.GroupingHandlerConfiguration
-
- getHandler() - Method in class org.hornetq.core.remoting.impl.invm.InVMAcceptor
-
- getHandler() - Method in class org.hornetq.core.remoting.impl.invm.InVMConnector
-
- getHeuristicCommittedTransactions() - Method in class org.hornetq.core.transaction.impl.ResourceManagerImpl
-
- getHeuristicCommittedTransactions() - Method in interface org.hornetq.core.transaction.ResourceManager
-
- getHeuristicRolledbackTransactions() - Method in class org.hornetq.core.transaction.impl.ResourceManagerImpl
-
- getHeuristicRolledbackTransactions() - Method in interface org.hornetq.core.transaction.ResourceManager
-
- getHistory() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
- getHistoryAsString() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
Get message counter history data as string in format
"day count\n
Date 1, hour counter 0, hour counter 1, ..., hour counter 23\n
Date 2, hour counter 0, hour counter 1, ..., hour counter 23\n
.....
- getHornetQServer() - Method in class org.hornetq.core.server.embedded.EmbeddedHornetQ
-
- getHornetQServerControl() - Method in interface org.hornetq.core.server.HornetQServer
-
Returns the resource to manage this HornetQ server.
- getHornetQServerControl() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getID() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- getId() - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- getId() - Method in interface org.hornetq.core.persistence.GroupingInfo
-
- getID() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PageCountPendingImpl
-
- getId() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PersistentQueueBindingEncoding
-
- getID() - Method in interface org.hornetq.core.persistence.impl.PageCountPending
-
- getId() - Method in interface org.hornetq.core.persistence.QueueBindingInfo
-
- getID() - Method in interface org.hornetq.core.postoffice.Binding
-
- getID() - Method in class org.hornetq.core.postoffice.impl.DivertBinding
-
- getID() - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- getID() - Method in class org.hornetq.core.postoffice.QueueInfo
-
- getId() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddMessage
-
- getId() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddTXMessage
-
- getId() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationDeleteMessage
-
- getId() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationDeleteTXMessage
-
- getId() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationSyncFileMessage
-
- getID() - Method in class org.hornetq.core.protocol.core.ServerSessionPacketHandler
-
- getID() - Method in class org.hornetq.core.remoting.impl.invm.InVMConnection
-
- getID() - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- getId() - Method in class org.hornetq.core.server.group.impl.GroupBinding
-
- getID() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getID() - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- getID() - Method in interface org.hornetq.core.server.Queue
-
- getID() - Method in interface org.hornetq.core.server.ServerConsumer
-
- getID() - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- getID() - Method in interface org.hornetq.core.transaction.Transaction
-
- getIDCacheSize() - Method in interface org.hornetq.core.config.Configuration
-
Returns the size of the cache for pre-creating message IDs.
- getIDCacheSize() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getIDCacheSize() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getIdentity() - Method in interface org.hornetq.core.server.HornetQServer
-
- getIdentity() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getIncomingInterceptorClassNames() - Method in interface org.hornetq.core.config.Configuration
-
Returns the list of interceptors classes used by this server for incoming messages (i.e.
- getIncomingInterceptorClassNames() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getIncomingInterceptorClassNames() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getInitialConnectAttempts() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getInitialConnectAttempts() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getInstantMessageCount() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getInstantMessageCount() - Method in interface org.hornetq.core.server.Queue
-
Return the current message count without waiting for scheduled executors to finish
- getInstantMessagesAdded() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getInstantMessagesAdded() - Method in interface org.hornetq.core.server.Queue
-
- getInteger(Element, String, int, Validators.Validator) - Static method in class org.hornetq.utils.XMLConfigurationUtil
-
- getInterceptorClassNames() - Method in interface org.hornetq.core.config.Configuration
-
- getInterceptorClassNames() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
Deprecated.
- getInterceptorClassNames() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getInTXMessagesForConsumer(long) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getInTXMessagesForConsumer(long) - Method in interface org.hornetq.core.server.ServerSession
-
- getJMXDomain() - Method in interface org.hornetq.core.config.Configuration
-
Returns the domain used by JMX MBeans (provided JMX management is enabled).
- getJMXDomain() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalBufferSize() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getJournalBufferSize_AIO() - Method in interface org.hornetq.core.config.Configuration
-
Returns the buffer size (in bytes) for AIO.
- getJournalBufferSize_AIO() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalBufferSize_NIO() - Method in interface org.hornetq.core.config.Configuration
-
Returns the buffer size (in bytes) for NIO.
- getJournalBufferSize_NIO() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalBufferTimeout() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getJournalBufferTimeout_AIO() - Method in interface org.hornetq.core.config.Configuration
-
Returns the timeout (in nanoseconds) used to flush buffers in the AIO queue.
- getJournalBufferTimeout_AIO() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalBufferTimeout_NIO() - Method in interface org.hornetq.core.config.Configuration
-
Returns the timeout (in nanoseconds) used to flush buffers in the NIO.
- getJournalBufferTimeout_NIO() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalCompactMinFiles() - Method in interface org.hornetq.core.config.Configuration
-
Returns the minimal number of journal files before compacting.
- getJournalCompactMinFiles() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalCompactMinFiles() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getJournalCompactPercentage() - Method in interface org.hornetq.core.config.Configuration
-
Returns the percentage of live data before compacting the journal.
- getJournalCompactPercentage() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalCompactPercentage() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getJournalContent() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationSyncFileMessage
-
- getJournalContentType(ReplicationStartSyncMessage.SyncDataType) - Static method in enum org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage.SyncDataType
-
- getJournalDirectory() - Method in interface org.hornetq.core.config.Configuration
-
Returns the file system directory used to store journal log.
- getJournalDirectory() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalDirectory() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getJournalFileSize() - Method in interface org.hornetq.core.config.Configuration
-
Returns the size (in bytes) of each journal files.
- getJournalFileSize() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalFileSize() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getJournalID() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddMessage
-
- getJournalID() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddTXMessage
-
- getJournalID() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationCommitMessage
-
- getJournalID() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationDeleteMessage
-
- getJournalID() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationDeleteTXMessage
-
- getJournalID() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPrepareMessage
-
- getJournalMaxIO() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getJournalMaxIO_AIO() - Method in interface org.hornetq.core.config.Configuration
-
Returns the maximum number of write requests that can be in the AIO queue at any given time.
- getJournalMaxIO_AIO() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalMaxIO_NIO() - Method in interface org.hornetq.core.config.Configuration
-
Returns the maximum number of write requests for NIO journal.
- getJournalMaxIO_NIO() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalMinFiles() - Method in interface org.hornetq.core.config.Configuration
-
Returns the number of journal files to pre-create.
- getJournalMinFiles() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalMinFiles() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getJournalPerfBlastPages() - Method in interface org.hornetq.core.config.Configuration
-
- getJournalPerfBlastPages() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalRecordType() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddMessage
-
- getJournalType() - Method in interface org.hornetq.core.config.Configuration
-
Returns the type of journal used by this server (either NIO
or ASYNCIO
).
- getJournalType() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getJournalType() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getKeyAttribute() - Method in class org.hornetq.core.deployers.impl.AddressSettingsDeployer
-
the key attribute for the element, usually 'name' but can be overridden
- getKeyAttribute() - Method in class org.hornetq.core.deployers.impl.SecurityDeployer
-
the key attribute for the element, usually 'name' but can be overridden
- getKeyAttribute() - Method in class org.hornetq.core.deployers.impl.XmlDeployer
-
The key attribute for the element, usually 'name' but can be overridden
- getLargeMessagesDirectory() - Method in interface org.hornetq.core.config.Configuration
-
Returns the file system directory used to store large messages.
- getLargeMessagesDirectory() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getLargeMessagesDirectory() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getLastAddedMessageTime() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
- getLastAddTimestamp() - Method in class org.hornetq.api.core.management.MessageCounterInfo
-
Returns the timestamp of the last time a message was added to the queue.
- getLastSentMessageID(String) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getLastSentMessageID(String) - Method in interface org.hornetq.core.server.ServerSession
-
- getLastUpdate() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
- getLinkedAddresses() - Method in interface org.hornetq.core.postoffice.Address
-
- getLinkedAddresses() - Method in class org.hornetq.core.postoffice.impl.AddressImpl
-
- getListOnConsumer(long) - Method in class org.hornetq.core.server.impl.QueueImpl.RefsOperation
-
- getListOnConsumer(long) - Method in interface org.hornetq.core.transaction.TransactionOperation
-
- getListOnConsumer(long) - Method in class org.hornetq.core.transaction.TransactionOperationAbstract
-
- getLiveConfiguration() - Method in class org.hornetq.core.server.impl.AnyLiveNodeLocator
-
- getLiveConfiguration() - Method in class org.hornetq.core.server.impl.NamedLiveNodeLocator
-
- getLiveConfiguration() - Method in class org.hornetq.core.server.LiveNodeLocator
-
Returns the current connector
- getLocalBindPort() - Method in class org.hornetq.core.management.impl.BroadcastGroupControlImpl
-
- getLong(Element, String, long, Validators.Validator) - Static method in class org.hornetq.utils.XMLConfigurationUtil
-
- getManagementAddress() - Method in interface org.hornetq.core.config.Configuration
-
Returns the management address of this server.
- getManagementAddress() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getManagementAddress() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getManagementAddress() - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- getManagementAddress() - Method in interface org.hornetq.core.server.management.ManagementService
-
- getManagementNotificationAddress() - Method in interface org.hornetq.core.config.Configuration
-
Returns the management notification address of this server.
- getManagementNotificationAddress() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getManagementNotificationAddress() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getManagementNotificationAddress() - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- getManagementNotificationAddress() - Method in interface org.hornetq.core.server.management.ManagementService
-
- getManagementService() - Method in interface org.hornetq.core.server.HornetQServer
-
- getManagementService() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getManageRoles() - Method in class org.hornetq.core.persistence.config.PersistedRoles
-
- getMatch(String) - Method in interface org.hornetq.core.settings.HierarchicalRepository
-
return the value held against the nearest match
- getMatch(String) - Method in class org.hornetq.core.settings.impl.HierarchicalObjectRepository
-
return the value held against the nearest match
- getMatch() - Method in class org.hornetq.core.settings.impl.Match
-
- getMatchingBindings(SimpleString) - Method in interface org.hornetq.core.postoffice.AddressManager
-
- getMatchingBindings(SimpleString) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- getMatchingBindings(SimpleString) - Method in class org.hornetq.core.postoffice.impl.SimpleAddressManager
-
- getMatchingBindings(SimpleString) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- getMaxDayCount() - Method in class org.hornetq.core.messagecounter.impl.MessageCounterManagerImpl
-
- getMaxDayCount() - Method in interface org.hornetq.core.messagecounter.MessageCounterManager
-
- getMaxDeliveryAttempts() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getMaxHops() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getMaxHops() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- getMaxHops() - Method in interface org.hornetq.core.server.cluster.MessageFlowRecord
-
- getMaxRedeliveryDelay() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getMaxRetryInterval() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getMaxRetryInterval() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getMaxSavedReplicatedJournalsSize() - Method in interface org.hornetq.core.config.Configuration
-
- getMaxSavedReplicatedJournalsSize() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getMaxSize() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getMaxSize() - Method in interface org.hornetq.core.paging.PagingStore
-
- getMaxSizeBytes() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getMBeanInfo() - Method in class org.hornetq.core.management.impl.AbstractControl
-
- getMBeanOperationsInfo(Class) - Static method in class org.hornetq.core.management.impl.MBeanInfoHelper
-
- getMemoryEstimate() - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl
-
- getMemoryEstimate() - Static method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- getMemoryEstimate() - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- getMemoryEstimate() - Method in interface org.hornetq.core.server.ServerMessage
-
- getMemoryMeasureInterval() - Method in interface org.hornetq.core.config.Configuration
-
- getMemoryMeasureInterval() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getMemoryWarningThreshold() - Method in interface org.hornetq.core.config.Configuration
-
- getMemoryWarningThreshold() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getMessage(int) - Method in class org.hornetq.core.paging.cursor.impl.LivePageCacheImpl
-
- getMessage(PagePosition) - Method in class org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl
-
- getMessage(int) - Method in interface org.hornetq.core.paging.cursor.PageCache
-
- getMessage(PagePosition) - Method in interface org.hornetq.core.paging.cursor.PageCursorProvider
-
- getMessage() - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- getMessage() - Method in class org.hornetq.core.paging.impl.PagedMessageImpl
-
- getMessage() - Method in interface org.hornetq.core.paging.PagedMessage
-
- getMessage() - Method in class org.hornetq.core.persistence.impl.journal.AddMessageRecord
-
- getMessage() - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- getMessage() - Method in interface org.hornetq.core.server.MessageReference
-
- getMessageCount() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- getMessageCount() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
Gets the current message count of pending messages
within the destination waiting for dispatch
- getMessageCount() - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- getMessageCount() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getMessageCount(long) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getMessageCount() - Method in interface org.hornetq.core.server.Queue
-
It will wait for up to 10 seconds for a flush on the executors and return the number of messages added.
- getMessageCount(long) - Method in interface org.hornetq.core.server.Queue
-
This method will return the messages added after waiting some time on the flush executors.
- getMessageCountDelta() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
Gets the message count delta of pending messages
since last method call.
- getMessageCounterHistoryDayLimit() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getMessageCounterManager() - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- getMessageCounterManager() - Method in interface org.hornetq.core.server.management.ManagementService
-
- getMessageCounterMaxDayCount() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getMessageCounterMaxDayHistory() - Method in interface org.hornetq.core.config.Configuration
-
Returns the maximum number of days kept in memory for message counter.
- getMessageCounterMaxDayHistory() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getMessageCounters() - Method in class org.hornetq.core.messagecounter.impl.MessageCounterManagerImpl
-
- getMessageCounterSamplePeriod() - Method in interface org.hornetq.core.config.Configuration
-
Returns the sample period (in milliseconds) to take message counter snapshot.
- getMessageCounterSamplePeriod() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getMessageCounterSamplePeriod() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getMessageExpiryScanPeriod() - Method in interface org.hornetq.core.config.Configuration
-
Returns the frequency (in milliseconds) to scan messages to detect which messages have
expired.
- getMessageExpiryScanPeriod() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getMessageExpiryScanPeriod() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getMessageExpiryThreadPriority() - Method in interface org.hornetq.core.config.Configuration
-
Returns the priority of the thread used to scan message expiration.
- getMessageExpiryThreadPriority() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getMessageExpiryThreadPriority() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getMessageId() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageBeginMessage
-
- getMessageId() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageEndMessage
-
- getMessageId() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageWriteMessage
-
- getMessageJournal() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- getMessageJournal() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- getMessageJournal() - Method in interface org.hornetq.core.persistence.StorageManager
-
- getMessageMemoryEstimate() - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- getMessageMemoryEstimate() - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- getMessageMemoryEstimate() - Method in interface org.hornetq.core.server.MessageReference
-
We define this method aggregation here because on paging we need to hold the original estimate,
so we need to perform some extra steps on paging.
- getMessageNr() - Method in class org.hornetq.core.paging.cursor.impl.PagePositionImpl
-
- getMessageNr() - Method in interface org.hornetq.core.paging.cursor.PagePosition
-
- getMessages() - Method in class org.hornetq.core.paging.cursor.impl.LivePageCacheImpl
-
- getMessages() - Method in interface org.hornetq.core.paging.cursor.PageCache
-
- getMessagesAdded() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- getMessagesAdded() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getMessagesAdded(long) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getMessagesAdded() - Method in interface org.hornetq.core.server.Queue
-
It will wait for up to 10 seconds for a flush on the executors and return the number of messages added.
- getMessagesAdded(long) - Method in interface org.hornetq.core.server.Queue
-
This method will return the messages added after waiting some time on the flush executors.
- getMetaData(String) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getMetaData(String) - Method in interface org.hornetq.core.server.ServerSession
-
- getMinLargeMessageSize() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getMinLargeMessageSize() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getMinLargeMessageSize() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getMinLargeMessageSize() - Method in interface org.hornetq.core.server.ServerSession
-
- getMsg() - Method in class org.hornetq.core.persistence.impl.journal.DescribeJournal.MessageDescribe
-
- getName() - Method in class org.hornetq.api.core.management.MessageCounterInfo
-
Returns the name of the queue.
- getName() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getName() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getName() - Method in interface org.hornetq.core.config.Configuration
-
To be used on dependency management on the application server
- getName() - Method in class org.hornetq.core.config.CoreQueueConfiguration
-
- getName() - Method in class org.hornetq.core.config.DivertConfiguration
-
- getName() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getName() - Method in class org.hornetq.core.management.impl.AcceptorControlImpl
-
- getName() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- getName() - Method in class org.hornetq.core.management.impl.BroadcastGroupControlImpl
-
- getName() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- getName() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- getName() - Method in interface org.hornetq.core.server.cluster.Bridge
-
- getName() - Method in interface org.hornetq.core.server.cluster.BroadcastGroup
-
- getName() - Method in interface org.hornetq.core.server.cluster.ClusterConnection
-
- getName() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- getName() - Method in class org.hornetq.core.server.cluster.impl.BroadcastGroupImpl
-
- getName() - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- getName() - Method in interface org.hornetq.core.server.ConnectorService
-
- getName() - Method in interface org.hornetq.core.server.group.GroupingHandler
-
- getName() - Method in class org.hornetq.core.server.group.impl.GroupingHandlerConfiguration
-
- getName() - Method in class org.hornetq.core.server.group.impl.LocalGroupingHandler
-
- getName() - Method in class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- getName() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getName() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getName() - Method in interface org.hornetq.core.server.Queue
-
- getName() - Method in interface org.hornetq.core.server.ServerSession
-
- getName() - Method in class org.hornetq.spi.core.security.JAASSecurityManager.SimplePrincipal
-
- getNodeGroupName() - Method in class org.hornetq.core.server.cluster.ClusterManager
-
- getNodeGroupName() - Method in class org.hornetq.core.server.NodeManager
-
- getNodeID() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- getNodeID() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage
-
- getNodeID() - Method in interface org.hornetq.core.server.cluster.ClusterConnection
-
- getNodeId() - Method in class org.hornetq.core.server.cluster.ClusterManager
-
- getNodeID() - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- getNodeID() - Method in interface org.hornetq.core.server.HornetQServer
-
- getNodeID() - Method in class org.hornetq.core.server.impl.AnyLiveNodeLocator
-
- getNodeID() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getNodeID() - Method in class org.hornetq.core.server.impl.NamedLiveNodeLocator
-
- getNodeID() - Method in class org.hornetq.core.server.LiveNodeLocator
-
Returns the node id for the current connector
- getNodeId() - Method in class org.hornetq.core.server.NodeManager
-
- getNodeManager() - Method in interface org.hornetq.core.server.HornetQServer
-
- getNodeManager() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getNodes() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- getNodes() - Method in interface org.hornetq.core.server.cluster.ClusterConnection
-
Only used for tests?
- getNodes() - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- getNonDurableQueues(SimpleString) - Method in class org.hornetq.core.server.impl.RoutingContextImpl
-
- getNonDurableQueues() - Method in interface org.hornetq.core.server.RouteContextList
-
- getNonDurableQueues(SimpleString) - Method in interface org.hornetq.core.server.RoutingContext
-
- getNotificationInfo() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getNotificationLock() - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- getNotificationLock() - Method in interface org.hornetq.core.postoffice.PostOffice
-
- getNumberOfBytesPerPage() - Method in class org.hornetq.core.management.impl.AddressControlImpl
-
- getNumberOfConsumers() - Method in class org.hornetq.core.postoffice.QueueInfo
-
- getNumberOfDurableQueues() - Method in interface org.hornetq.core.server.RouteContextList
-
- getNumberOfMessages() - Method in class org.hornetq.core.management.impl.AddressControlImpl
-
- getNumberOfMessages() - Method in class org.hornetq.core.paging.cursor.impl.LivePageCacheImpl
-
- getNumberOfMessages() - Method in interface org.hornetq.core.paging.cursor.PageCache
-
- getNumberOfMessages() - Method in class org.hornetq.core.paging.impl.Page
-
- getNumberOfMessages() - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- getNumberOfMessages() - Method in interface org.hornetq.core.paging.PageTransactionInfo
-
- getNumberOfNonDurableQueues() - Method in interface org.hornetq.core.server.RouteContextList
-
- getNumberOfPages() - Method in class org.hornetq.core.management.impl.AddressControlImpl
-
- getNumberOfPages() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getNumberOfPages() - Method in interface org.hornetq.core.paging.PagingStore
-
- getNumberOfRecords() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- getNumberOfReferences() - Method in class org.hornetq.core.server.impl.QueueImpl
-
Used on testing only *
- getObjectNameBuilder() - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- getObjectNameBuilder() - Method in interface org.hornetq.core.server.management.ManagementService
-
- getOperation() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddTXMessage
-
- getOutgoingInterceptorClassNames() - Method in interface org.hornetq.core.config.Configuration
-
Returns the list of interceptors classes used by this server for outgoing messages (i.e.
- getOutgoingInterceptorClassNames() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getOutgoingInterceptorClassNames() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getPageCache(long) - Method in class org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl
-
- getPageCache(long) - Method in interface org.hornetq.core.paging.cursor.PageCursorProvider
-
- getPageCacheMaxSize() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getPagedMessage() - Method in interface org.hornetq.core.paging.cursor.PagedReference
-
- getPagedMessage() - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- getPagedMessage() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPageWriteMessage
-
- getPageId() - Method in class org.hornetq.core.paging.cursor.impl.LivePageCacheImpl
-
- getPageId() - Method in interface org.hornetq.core.paging.cursor.PageCache
-
- getPageId() - Method in class org.hornetq.core.paging.impl.Page
-
- getPageID() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PageCountPendingImpl
-
- getPageID() - Method in interface org.hornetq.core.persistence.impl.PageCountPending
-
- getPageMaxConcurrentIO() - Method in interface org.hornetq.core.config.Configuration
-
The max number of concurrent reads allowed on paging.
- getPageMaxConcurrentIO() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getPageNr() - Method in class org.hornetq.core.paging.cursor.impl.PagePositionImpl
-
- getPageNr() - Method in interface org.hornetq.core.paging.cursor.PagePosition
-
- getPageNumber() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPageEventMessage
-
- getPageNumber() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPageWriteMessage
-
- getPageSizeBytes() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getPageSizeBytes() - Method in interface org.hornetq.core.paging.PagingStore
-
- getPageSizeBytes() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getPageStore(SimpleString) - Method in class org.hornetq.core.paging.impl.PagingManagerImpl
-
stores is a ConcurrentHashMap, so we don't need to synchronize this method
- getPageStore(SimpleString) - Method in interface org.hornetq.core.paging.PagingManager
-
Returns the PageStore associated with the address.
- getPageStore() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationSyncFileMessage
-
- getPageSubscription() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getPageSubscription() - Method in interface org.hornetq.core.server.Queue
-
- getPagingDirectory() - Method in interface org.hornetq.core.config.Configuration
-
Returns the file system directory used to store paging files.
- getPagingDirectory() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getPagingDirectory() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getPagingManager() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getPagingManager() - Method in interface org.hornetq.core.paging.PagingStore
-
- getPagingManager() - Method in interface org.hornetq.core.server.HornetQServer
-
- getPagingManager() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getPagingStore() - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- getPagingStore() - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- getPagingStore() - Method in interface org.hornetq.core.server.ServerMessage
-
- getParameters() - Method in class org.hornetq.core.management.impl.AcceptorControlImpl
-
- getParams() - Method in class org.hornetq.core.config.ConnectorServiceConfiguration
-
- getPassword() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getPassword() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getPassword() - Method in interface org.hornetq.core.server.ServerSession
-
- getPasswordCodec() - Method in interface org.hornetq.core.config.Configuration
-
Gets the default password decoder
- getPasswordCodec() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getPattern() - Method in class org.hornetq.core.settings.impl.Match
-
- getPendingRecordID() - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl
-
- getPendingRecordID() - Method in interface org.hornetq.core.server.LargeServerMessage
-
- getPersistedCount() - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- getPersistedCount() - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- getPersistedCount() - Method in interface org.hornetq.core.server.MessageReference
-
- getPosition() - Method in interface org.hornetq.core.paging.cursor.PagedReference
-
- getPosition() - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- getPostOffice() - Method in interface org.hornetq.core.server.HornetQServer
-
- getPostOffice() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getPreparedTransactions() - Method in class org.hornetq.core.transaction.impl.ResourceManagerImpl
-
- getPreparedTransactions() - Method in interface org.hornetq.core.transaction.ResourceManager
-
- getPreparedTransactionsWithCreationTime() - Method in class org.hornetq.core.transaction.impl.ResourceManagerImpl
-
- getPreparedTransactionsWithCreationTime() - Method in interface org.hornetq.core.transaction.ResourceManager
-
- getProperty(int) - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- getProperty(int) - Method in interface org.hornetq.core.transaction.Transaction
-
- getProposal(SimpleString, boolean) - Method in interface org.hornetq.core.server.group.GroupingHandler
-
- getProposal(SimpleString, boolean) - Method in class org.hornetq.core.server.group.impl.LocalGroupingHandler
-
- getProposal(SimpleString, boolean) - Method in class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- getProtocolDecoder() - Method in class org.hornetq.core.protocol.ProtocolHandler
-
- getProtocols() - Method in class org.hornetq.core.protocol.core.impl.CoreProtocolManagerFactory
-
- getProtocols() - Method in interface org.hornetq.spi.core.protocol.ProtocolManagerFactory
-
- getQueue() - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- getQueue() - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- getQueue() - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- getQueue() - Method in interface org.hornetq.core.postoffice.QueueBinding
-
- getQueue() - Method in interface org.hornetq.core.server.cluster.Bridge
-
- getQueue() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- getQueue() - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- getQueue() - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- getQueue() - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- getQueue() - Method in interface org.hornetq.core.server.MessageReference
-
- getQueue() - Method in interface org.hornetq.core.server.ServerConsumer
-
- getQueueConfigurations() - Method in interface org.hornetq.core.config.Configuration
-
Returns the queues configured for this server.
- getQueueConfigurations() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getQueueCount() - Method in class org.hornetq.core.server.impl.RoutingContextImpl
-
- getQueueCount() - Method in interface org.hornetq.core.server.RoutingContext
-
- getQueueFactory() - Method in interface org.hornetq.core.server.HornetQServer
-
- getQueueFactory() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getQueueID() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PageCountPendingImpl
-
- getQueueID() - Method in interface org.hornetq.core.persistence.impl.PageCountPending
-
- getQueueIDs() - Method in class org.hornetq.core.paging.impl.PagedMessageImpl
-
- getQueueIDs() - Method in interface org.hornetq.core.paging.PagedMessage
-
The queues that were routed during paging
- getQueueName() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getQueueName() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- getQueueName() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PersistentQueueBindingEncoding
-
- getQueueName() - Method in interface org.hornetq.core.persistence.QueueBindingInfo
-
- getQueueName() - Method in class org.hornetq.core.server.impl.TransientQueueManagerImpl
-
- getQueueName() - Method in interface org.hornetq.core.server.TransientQueueManager
-
- getQueueNames() - Method in class org.hornetq.core.management.impl.AddressControlImpl
-
- getQueueNames() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getQueueNames() - Method in class org.hornetq.core.server.BindingQueryResult
-
- getRate() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getRate() - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- getRate() - Method in interface org.hornetq.core.server.Queue
-
- getReaperPeriod() - Method in class org.hornetq.core.server.group.impl.GroupingHandlerConfiguration
-
- getReconnectAttempts() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getReconnectAttempts() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getReconnectAttempts() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- getReconnectAttemptsOnSameNode() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getRecord() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddMessage
-
- getRecordData() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddMessage
-
- getRecordData() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddTXMessage
-
- getRecordData() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationDeleteTXMessage
-
- getRecordData() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPrepareMessage
-
- getRecordID() - Method in class org.hornetq.core.paging.cursor.impl.PagePositionImpl
-
- getRecordID() - Method in interface org.hornetq.core.paging.cursor.PagePosition
-
- getRecordID() - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- getRecordID() - Method in interface org.hornetq.core.paging.PageTransactionInfo
-
- getRecords() - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- getRecordType() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddTXMessage
-
- getRedeliveryDelay() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getRedeliveryMultiplier() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getRedistributionDelay() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getRefCount() - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- getRefCount() - Method in interface org.hornetq.core.server.ServerMessage
-
- getReference(long) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getReference(long) - Method in interface org.hornetq.core.server.Queue
-
- getRegistrationProblem() - Method in class org.hornetq.core.protocol.core.impl.wireformat.BackupReplicationStartFailedMessage
-
- getRelatedMessageReferences() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PageUpdateTXEncoding
-
- getRelatedMessageReferences() - Method in class org.hornetq.core.server.impl.QueueImpl.RefsOperation
-
- getRelatedMessageReferences() - Method in interface org.hornetq.core.transaction.TransactionOperation
-
- getRelatedMessageReferences() - Method in class org.hornetq.core.transaction.TransactionOperationAbstract
-
- getRemoteAddress() - Method in class org.hornetq.core.remoting.impl.invm.InVMConnection
-
- getRemotingConnection() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getRemotingConnection() - Method in interface org.hornetq.core.server.ServerSession
-
- getRemotingService() - Method in interface org.hornetq.core.server.HornetQServer
-
- getRemotingService() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getReplicationClusterConfiguration(Configuration) - Static method in class org.hornetq.core.config.ConfigurationUtils
-
- getReplicationClustername() - Method in interface org.hornetq.core.config.Configuration
-
- getReplicationClustername() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getReplicationEndpoint() - Method in interface org.hornetq.core.server.HornetQServer
-
- getReplicationEndpoint() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getReplicationManager() - Method in interface org.hornetq.core.server.HornetQServer
-
- getReplicationManager() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getRequiredProperties() - Method in interface org.hornetq.core.server.ConnectorServiceFactory
-
- getResource(String) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- getResource(String) - Method in interface org.hornetq.core.server.management.ManagementService
-
- getResourceManager() - Method in interface org.hornetq.core.server.HornetQServer
-
- getResourceManager() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getResources(Class<?>) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- getResources(Class<?>) - Method in interface org.hornetq.core.server.management.ManagementService
-
- getRetryInterval() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getRetryInterval() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getRetryInterval() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- getRetryInterval() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- getRetryIntervalMultiplier() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getRetryIntervalMultiplier() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getRetryIntervalMultiplier() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- getRoles() - Method in class org.hornetq.core.management.impl.AddressControlImpl
-
- getRoles(String) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getRolesAsJSON() - Method in class org.hornetq.core.management.impl.AddressControlImpl
-
- getRolesAsJSON(String) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getRootElement(URI) - Method in class org.hornetq.core.deployers.impl.XmlDeployer
-
- getRoutingName() - Method in class org.hornetq.core.config.DivertConfiguration
-
- getRoutingName() - Method in class org.hornetq.core.management.impl.DivertControlImpl
-
- getRoutingName() - Method in interface org.hornetq.core.postoffice.Binding
-
- getRoutingName() - Method in class org.hornetq.core.postoffice.impl.DivertBinding
-
- getRoutingName() - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- getRoutingName() - Method in class org.hornetq.core.postoffice.QueueInfo
-
- getRoutingName() - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- getRoutingName() - Method in interface org.hornetq.core.server.Divert
-
- getRoutingName() - Method in class org.hornetq.core.server.impl.DivertImpl
-
- getRoutingName() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getSamplePeriod() - Method in class org.hornetq.core.messagecounter.impl.MessageCounterManagerImpl
-
- getSamplePeriod() - Method in interface org.hornetq.core.messagecounter.MessageCounterManager
-
- getScheduledCount() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- getScheduledCount() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getScheduledCount() - Method in class org.hornetq.core.server.impl.ScheduledDeliveryHandlerImpl
-
- getScheduledCount() - Method in interface org.hornetq.core.server.Queue
-
- getScheduledCount() - Method in interface org.hornetq.core.server.ScheduledDeliveryHandler
-
- getScheduledDeliveryTime() - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- getScheduledDeliveryTime() - Method in class org.hornetq.core.persistence.impl.journal.AddMessageRecord
-
- getScheduledDeliveryTime() - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- getScheduledDeliveryTime() - Method in interface org.hornetq.core.server.MessageReference
-
- getScheduledMessages() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getScheduledMessages() - Method in interface org.hornetq.core.server.Queue
-
- getScheduledPool() - Method in interface org.hornetq.core.server.HornetQServer
-
- getScheduledPool() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getScheduledReferences() - Method in class org.hornetq.core.server.impl.ScheduledDeliveryHandlerImpl
-
- getScheduledReferences() - Method in interface org.hornetq.core.server.ScheduledDeliveryHandler
-
- getScheduledThreadPoolMaxSize() - Method in interface org.hornetq.core.config.Configuration
-
Returns the maximum number of threads in the scheduled thread pool of this server.
- getScheduledThreadPoolMaxSize() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getScheduledThreadPoolMaxSize() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getSecurityInvalidationInterval() - Method in interface org.hornetq.core.config.Configuration
-
Returns the interval time (in milliseconds) to invalidate security credentials.
- getSecurityInvalidationInterval() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getSecurityInvalidationInterval() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getSecurityManager() - Method in interface org.hornetq.core.server.HornetQServer
-
- getSecurityManager() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getSecurityRepository() - Method in interface org.hornetq.core.server.HornetQServer
-
- getSecurityRepository() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getSecurityRoles() - Method in interface org.hornetq.core.config.Configuration
-
- getSecurityRoles() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getSecurityStore() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getSendRoles() - Method in class org.hornetq.core.persistence.config.PersistedRoles
-
- getServer() - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- getServer() - Method in interface org.hornetq.core.server.cluster.ClusterConnection
-
- getServer() - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- getServerConsumers() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getServerConsumers() - Method in interface org.hornetq.core.server.ServerSession
-
- getServerDumpInterval() - Method in interface org.hornetq.core.config.Configuration
-
- getServerDumpInterval() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getSession() - Method in class org.hornetq.core.protocol.core.ServerSessionPacketHandler
-
- getSessionByID(String) - Method in interface org.hornetq.core.server.HornetQServer
-
- getSessionByID(String) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getSessionContext() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getSessionContext() - Method in interface org.hornetq.core.server.ServerSession
-
- getSessionID() - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- getSessionID() - Method in interface org.hornetq.core.server.ServerConsumer
-
- getSessions() - Method in interface org.hornetq.core.server.HornetQServer
-
- getSessions(String) - Method in interface org.hornetq.core.server.HornetQServer
-
- getSessions(String) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getSessions() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getSetting() - Method in class org.hornetq.core.persistence.config.PersistedAddressSetting
-
- getSingleThreadExecutor() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- getSize() - Method in class org.hornetq.core.paging.impl.Page
-
- getSlowConsumerCheckPeriod() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getSlowConsumerPolicy() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getSlowConsumerThreshold() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- getState() - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- getState() - Method in interface org.hornetq.core.transaction.Transaction
-
- getStaticConnectors() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getStaticConnectors() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- getStaticConnectors() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- getStaticConnectors() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- getStaticConnectorsAsJSON() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- getStorageManager() - Method in interface org.hornetq.core.server.HornetQServer
-
- getStorageManager() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getStorageManager() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getStoreId() - Method in class org.hornetq.core.persistence.config.PersistedAddressSetting
-
- getStoreId() - Method in class org.hornetq.core.persistence.config.PersistedRoles
-
- getStoreName() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- getStoreName() - Method in interface org.hornetq.core.paging.PagingStore
-
- getStoreName() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPageEventMessage
-
- getStoreNames() - Method in class org.hornetq.core.paging.impl.PagingManagerImpl
-
- getStoreNames() - Method in interface org.hornetq.core.paging.PagingManager
-
- getString(Element, String, String, Validators.Validator) - Static method in class org.hornetq.utils.XMLConfigurationUtil
-
- getSubscription() - Method in class org.hornetq.api.core.management.MessageCounterInfo
-
Returns the name of the subscription.
- getSubscription(long) - Method in class org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl
-
- getSubscription(long) - Method in interface org.hornetq.core.paging.cursor.PageCursorProvider
-
- getSyncFile() - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageInSync
-
- getTargetAddresses() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getTargetAddresses() - Method in interface org.hornetq.core.server.ServerSession
-
- getTargetNodeFromTopology() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
for use in tests mainly
- getThreadPoolMaxSize() - Method in interface org.hornetq.core.config.Configuration
-
Returns the maximum number of threads in the thread pool of this server.
- getThreadPoolMaxSize() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getThreadPoolMaxSize() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getTimeout() - Method in class org.hornetq.core.server.group.impl.GroupingHandlerConfiguration
-
- getTimeoutSeconds() - Method in class org.hornetq.core.transaction.impl.ResourceManagerImpl
-
- getTimeoutSeconds() - Method in interface org.hornetq.core.transaction.ResourceManager
-
- getTimeUsed() - Method in class org.hornetq.core.server.group.impl.GroupBinding
-
- getTimeUsed() - Method in class org.hornetq.core.server.group.impl.Response
-
- getTopology() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- getTopology() - Method in interface org.hornetq.core.server.cluster.ClusterConnection
-
- getTopology() - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- getTransaction(long) - Method in class org.hornetq.core.paging.impl.PagingManagerImpl
-
- getTransaction(long) - Method in interface org.hornetq.core.paging.PagingManager
-
Point to inform/restoring Transactions used when the messages were added into paging
- getTransaction() - Method in class org.hornetq.core.server.impl.RoutingContextImpl
-
- getTransaction() - Method in interface org.hornetq.core.server.RoutingContext
-
- getTransaction(Xid) - Method in class org.hornetq.core.transaction.impl.ResourceManagerImpl
-
- getTransaction(Xid) - Method in interface org.hornetq.core.transaction.ResourceManager
-
- getTransactionID() - Method in class org.hornetq.core.paging.impl.PagedMessageImpl
-
- getTransactionID() - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- getTransactionID() - Method in interface org.hornetq.core.paging.PagedMessage
-
- getTransactionID() - Method in interface org.hornetq.core.paging.PageTransactionInfo
-
- getTransactions() - Method in class org.hornetq.core.paging.impl.PagingManagerImpl
-
- getTransactions() - Method in interface org.hornetq.core.paging.PagingManager
-
- getTransactionTimeout() - Method in interface org.hornetq.core.config.Configuration
-
Returns the timeout (in milliseconds) after which transactions is removed from the resource
manager after it was created.
- getTransactionTimeout() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getTransactionTimeout() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getTransactionTimeoutScanPeriod() - Method in interface org.hornetq.core.config.Configuration
-
Returns the frequency (in milliseconds) to scan transactions to detect which transactions have
timed out.
- getTransactionTimeoutScanPeriod() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- getTransactionTimeoutScanPeriod() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getTransformerClassName() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getTransformerClassName() - Method in class org.hornetq.core.config.DivertConfiguration
-
- getTransformerClassName() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- getTransformerClassName() - Method in class org.hornetq.core.management.impl.DivertControlImpl
-
- getTransportConfiguration(ClusterConnectionConfiguration, Configuration) - Static method in class org.hornetq.core.server.cluster.ClusterConfigurationUtil
-
- getTransportConfigurations(ClusterConnectionConfiguration, Configuration) - Static method in class org.hornetq.core.server.cluster.ClusterConfigurationUtil
-
- getTrimmedTextContent(Node) - Static method in class org.hornetq.utils.XMLConfigurationUtil
-
- getTxId() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddTXMessage
-
- getTxId() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationCommitMessage
-
- getTxId() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationDeleteTXMessage
-
- getTxId() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPrepareMessage
-
- getType(byte) - Static method in enum org.hornetq.core.persistence.impl.journal.JournalStorageManager.JournalContent
-
- getType() - Method in interface org.hornetq.core.postoffice.Binding
-
- getType() - Method in class org.hornetq.core.postoffice.impl.DivertBinding
-
- getType() - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- getType() - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- getType() - Method in class org.hornetq.core.server.group.impl.GroupingHandlerConfiguration
-
- getType() - Method in enum org.hornetq.core.server.group.impl.GroupingHandlerConfiguration.TYPE
-
- getUdpateTimestamp() - Method in class org.hornetq.api.core.management.MessageCounterInfo
-
Returns the timestamp of the last time the queue was updated.
- getUniqueName() - Method in class org.hornetq.core.management.impl.DivertControlImpl
-
- getUniqueName() - Method in interface org.hornetq.core.postoffice.Binding
-
- getUniqueName() - Method in class org.hornetq.core.postoffice.impl.DivertBinding
-
- getUniqueName() - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- getUniqueName() - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- getUniqueName() - Method in interface org.hornetq.core.server.Divert
-
- getUniqueName() - Method in class org.hornetq.core.server.impl.DivertImpl
-
- getUniqueName() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- getUser() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- getUsername() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- getUsername() - Method in interface org.hornetq.core.server.ServerSession
-
- getUserVersion() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- getUUID() - Method in class org.hornetq.core.server.NodeManager
-
- getValue() - Method in class org.hornetq.core.paging.cursor.impl.PageSubscriptionCounterImpl
-
- getValue() - Method in interface org.hornetq.core.paging.cursor.PageSubscriptionCounter
-
- getValue() - Method in class org.hornetq.core.settings.impl.Match
-
- getVersion() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- getVersion() - Method in interface org.hornetq.core.server.HornetQServer
-
- getVersion() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- getXid() - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- getXid() - Method in interface org.hornetq.core.transaction.Transaction
-
- gotBackupLock() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- greaterThanMinusOne(String, Number) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- greaterThanZero(String, Number) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- greaterThanZero(Integer) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- greaterThanZeroOrMinusOne(String, Number) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- GROUP_TIMEOUT_PROP_NAME - Static variable in class org.hornetq.core.server.group.impl.GroupingHandlerConfiguration
-
- GroupBinding - Class in org.hornetq.core.server.group.impl
-
A group binding
- GroupBinding(SimpleString, SimpleString) - Constructor for class org.hornetq.core.server.group.impl.GroupBinding
-
- GroupBinding(long, SimpleString, SimpleString) - Constructor for class org.hornetq.core.server.group.impl.GroupBinding
-
- groupHandlerSendTimeout() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- GroupHandlingAbstract - Class in org.hornetq.core.server.group.impl
-
- GroupHandlingAbstract(Executor, ManagementService, SimpleString) - Constructor for class org.hornetq.core.server.group.impl.GroupHandlingAbstract
-
- GroupingHandler - Interface in org.hornetq.core.server.group
-
- groupingHandlerConfiguration - Variable in class org.hornetq.core.config.impl.ConfigurationImpl
-
- GroupingHandlerConfiguration - Class in org.hornetq.core.server.group.impl
-
A remote Grouping handler configuration
- GroupingHandlerConfiguration(SimpleString, GroupingHandlerConfiguration.TYPE, SimpleString) - Constructor for class org.hornetq.core.server.group.impl.GroupingHandlerConfiguration
-
- GroupingHandlerConfiguration(SimpleString, GroupingHandlerConfiguration.TYPE, SimpleString, int) - Constructor for class org.hornetq.core.server.group.impl.GroupingHandlerConfiguration
-
- GroupingHandlerConfiguration(SimpleString, GroupingHandlerConfiguration.TYPE, SimpleString, int, long, long) - Constructor for class org.hornetq.core.server.group.impl.GroupingHandlerConfiguration
-
- GroupingHandlerConfiguration.TYPE - Enum in org.hornetq.core.server.group.impl
-
- GroupingInfo - Interface in org.hornetq.core.persistence
-
- groupingQueueRemoved(SimpleString) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- groupingQueueRemoved(int, SimpleString) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- groupWhileStopping() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- GT_ZERO - Static variable in class org.hornetq.core.config.impl.Validators
-
- id - Variable in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PersistentQueueBindingEncoding
-
- id - Variable in class org.hornetq.core.remoting.impl.invm.InVMConnector
-
- ID_COUNTER_RECORD - Static variable in class org.hornetq.core.persistence.impl.journal.JournalRecordIds
-
Records storing the current recordID number.
- idCacheSize - Variable in class org.hornetq.core.config.impl.ConfigurationImpl
-
- ignoreRedeliveryCheck - Variable in class org.hornetq.core.server.impl.QueueImpl.RefsOperation
-
It will ignore redelivery check, which is used during consumer.close
to not perform reschedule redelivery check
- impossibleToRouteGrouped() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- IncomingInterceptorLookingForExceptionMessage(ClusterManager, Executor) - Constructor for class org.hornetq.core.server.cluster.ClusterManager.IncomingInterceptorLookingForExceptionMessage
-
- incompatibleClientServer() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- incompatibleVersionAfterConnect(int, int) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- incompatibleWithHAPolicy(String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- increment(Transaction, int) - Method in class org.hornetq.core.paging.cursor.impl.PageSubscriptionCounterImpl
-
- increment(Transaction, int) - Method in interface org.hornetq.core.paging.cursor.PageSubscriptionCounter
-
- increment(int, int) - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- increment(int, int) - Method in interface org.hornetq.core.paging.PageTransactionInfo
-
- increment() - Method in class org.hornetq.core.server.impl.TransientQueueManagerImpl
-
- incrementConsumers() - Method in class org.hornetq.core.postoffice.QueueInfo
-
- incrementDelayDeletionCount() - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl
-
- incrementDelayDeletionCount() - Method in interface org.hornetq.core.server.LargeServerMessage
-
- incrementDeliveryCount() - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- incrementDeliveryCount() - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- incrementDeliveryCount() - Method in interface org.hornetq.core.server.MessageReference
-
- incrementDurableRefCount() - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- incrementDurableRefCount() - Method in interface org.hornetq.core.server.ServerMessage
-
- incrementProcessed(long, int) - Method in class org.hornetq.core.paging.cursor.impl.PageSubscriptionCounterImpl
-
- incrementRefCount() - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- incrementRefCount() - Method in interface org.hornetq.core.server.ServerMessage
-
- individualAcknowledge(boolean, Transaction, long) - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- individualAcknowledge(long, long) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- individualAcknowledge(boolean, Transaction, long) - Method in interface org.hornetq.core.server.ServerConsumer
-
- individualAcknowledge(long, long) - Method in interface org.hornetq.core.server.ServerSession
-
- individualCancel(long, boolean) - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- individualCancel(long, long, boolean) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- individualCancel(long, boolean) - Method in interface org.hornetq.core.server.ServerConsumer
-
- individualCancel(long, long, boolean) - Method in interface org.hornetq.core.server.ServerSession
-
- informClusterOfBackup() - Method in interface org.hornetq.core.server.cluster.ClusterConnection
-
- informClusterOfBackup(String) - Method in class org.hornetq.core.server.cluster.ClusterManager
-
- informClusterOfBackup() - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- initializationError(Throwable) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- initMessage(StorageManager) - Method in class org.hornetq.core.paging.impl.PagedMessageImpl
-
- initMessage(StorageManager) - Method in interface org.hornetq.core.paging.PagedMessage
-
- initQueues(Map<Long, QueueBindingInfo>, List<QueueBindingInfo>) - Method in interface org.hornetq.core.server.impl.JournalLoader
-
- initQueues(Map<Long, QueueBindingInfo>, List<QueueBindingInfo>) - Method in class org.hornetq.core.server.impl.PostOfficeJournalLoader
-
- initStart() - Method in class org.hornetq.core.server.embedded.EmbeddedHornetQ
-
- INSTANCE - Static variable in class org.hornetq.core.protocol.ServerPacketDecoder
-
- instance - Static variable in class org.hornetq.core.remoting.impl.invm.InVMRegistry
-
- intercept(Packet, RemotingConnection) - Method in class org.hornetq.core.server.cluster.ClusterManager.IncomingInterceptorLookingForExceptionMessage
-
- internalCreateConnection(BufferHandler, ConnectionLifeCycleListener, Executor) - Method in class org.hornetq.core.remoting.impl.invm.InVMConnector
-
- internalCreateSession(String, String, String, int, RemotingConnection, boolean, boolean, boolean, boolean, String, SessionCallback, OperationContext) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- internalUpdatePageManager(StorageManager, PagingManager, Transaction, int) - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- interrupt() - Method in class org.hornetq.core.server.impl.FileLockNodeManager
-
- interrupt() - Method in class org.hornetq.core.server.NodeManager
-
- interrupted - Variable in class org.hornetq.core.server.impl.FileLockNodeManager
-
- invalidAcceptorKeys(String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- invalidAddressFullPolicyType(String) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- invalidCipherSuite(String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- invalidFilter(Throwable, SimpleString) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- invalidFilter(Throwable, SimpleString) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- invalidIndex(Integer) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- invalidJournal() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- invalidJournalType(String) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- invalidJournalType2(JournalType) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- invalidMatch() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- invalidMessageCounterPeriod(Long) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- invalidNewPriority(Integer) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- invalidPacket(Packet) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- invalidPacketForReplication(Packet) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- invalidPageIO() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- invalidProtocol(String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- invalidRetryInterval(Long) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- invalidSlowConsumerPolicyType(String) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- invalidType(Object) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- InVMAcceptor - Class in org.hornetq.core.remoting.impl.invm
-
A InVMAcceptor
- InVMAcceptor(ClusterConnection, Map<String, Object>, BufferHandler, ConnectionLifeCycleListener, Executor) - Constructor for class org.hornetq.core.remoting.impl.invm.InVMAcceptor
-
- InVMAcceptorFactory - Class in org.hornetq.core.remoting.impl.invm
-
A InVMAcceptorFactory
- InVMAcceptorFactory() - Constructor for class org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory
-
- InVMConnection - Class in org.hornetq.core.remoting.impl.invm
-
A InVMConnection
- InVMConnection(int, BufferHandler, ConnectionLifeCycleListener, Executor) - Constructor for class org.hornetq.core.remoting.impl.invm.InVMConnection
-
- InVMConnection(int, String, BufferHandler, ConnectionLifeCycleListener, Executor) - Constructor for class org.hornetq.core.remoting.impl.invm.InVMConnection
-
- InVMConnection(int, String, BufferHandler, ConnectionLifeCycleListener, Executor, HornetQPrincipal) - Constructor for class org.hornetq.core.remoting.impl.invm.InVMConnection
-
- InVMConnector - Class in org.hornetq.core.remoting.impl.invm
-
A InVMConnector
- InVMConnector(Map<String, Object>, BufferHandler, ConnectionLifeCycleListener, Executor, Executor) - Constructor for class org.hornetq.core.remoting.impl.invm.InVMConnector
-
- InVMConnectorFactory - Class in org.hornetq.core.remoting.impl.invm
-
A InVMConnectorFactory
- InVMConnectorFactory() - Constructor for class org.hornetq.core.remoting.impl.invm.InVMConnectorFactory
-
- InVMRegistry - Class in org.hornetq.core.remoting.impl.invm
-
A InVMRegistry
- InVMRegistry() - Constructor for class org.hornetq.core.remoting.impl.invm.InVMRegistry
-
- ioCriticalIOError(String, String, Throwable) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- ioErrorAddingReferences(Integer, String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- ioErrorOnTX(Integer, String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- ioErrorRedistributing(Integer, String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- ioSync() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- ioSync() - Method in interface org.hornetq.core.paging.PagingStore
-
Performs a real sync on the current IO file.
- ioTimeout() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- isAccepted() - Method in class org.hornetq.core.server.group.impl.Response
-
- isActive() - Method in interface org.hornetq.core.server.HornetQServer
-
- isActive() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- isAddressBound(SimpleString) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- isAddressBound(SimpleString) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- isAddressBound(String) - Method in interface org.hornetq.core.server.HornetQServer
-
return true if there is a binding for this address (i.e.
- isAddressBound(String) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- isAllowAutoFailBack() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether a backup will automatically stop when a live server is restarting (i.e.
- isAllowAutoFailBack() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isAllowDirectConnectionsOnly() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- isAsyncConnectionExecutionEnabled() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether code coming from connection is executed asynchronously or not.
- isAsyncConnectionExecutionEnabled() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isAsyncConnectionExecutionEnabled() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isAwaitingFailback() - Method in class org.hornetq.core.server.impl.FileLockNodeManager
-
- isAwaitingFailback() - Method in class org.hornetq.core.server.NodeManager
-
- isBackup() - Method in interface org.hornetq.core.config.Configuration
-
Returns true
if this server is a backup, false
if it is a live server.
- isBackup() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isBackup() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isBackupAnnounced() - Method in class org.hornetq.core.server.cluster.BackupManager
-
- isBackupLive() - Method in class org.hornetq.core.server.impl.FileLockNodeManager
-
- isBackupLive() - Method in class org.hornetq.core.server.NodeManager
-
- isBrowseOnly() - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- isBrowseOnly() - Method in interface org.hornetq.core.server.ServerConsumer
-
- isCheckForLiveServer() - Method in interface org.hornetq.core.config.Configuration
-
Whether to check if the cluster already has a (live) node with our node-ID.
- isCheckForLiveServer() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isClosed() - Method in interface org.hornetq.core.server.cluster.MessageFlowRecord
-
- isClustered() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether this server is clustered.
- isClustered() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isClustered() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isCommit() - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- isCommit() - Method in interface org.hornetq.core.paging.PageTransactionInfo
-
- isCommit - Variable in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.HeuristicCompletionEncoding
-
- isComplete(long) - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- isConnected() - Method in interface org.hornetq.core.server.cluster.Bridge
-
- isConnected() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- isContainsPersistent() - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- isContainsPersistent() - Method in interface org.hornetq.core.transaction.Transaction
-
- isCreateBindingsDir() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether the bindings directory is created on this server startup.
- isCreateBindingsDir() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isCreateBindingsDir() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isCreateJournalDir() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether the journal directory is created on this server startup.
- isCreateJournalDir() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isCreateJournalDir() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isDelete() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPageEventMessage
-
- isDestinationDurable() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
- isDestinationTopic() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
- isDirectDeliver() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- isDirectDeliver() - Method in interface org.hornetq.core.server.Queue
-
- isDuplicateDetection() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- isDuplicateDetection() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- isDurable() - Method in class org.hornetq.api.core.management.MessageCounterInfo
-
Returns whether the queue is durable.
- isDurable() - Method in class org.hornetq.core.config.CoreQueueConfiguration
-
- isDurable() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- isDurable() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- isDurable() - Method in interface org.hornetq.core.server.Queue
-
- isEquivalent(Map<String, Object>) - Method in class org.hornetq.core.remoting.impl.invm.InVMConnector
-
- isExclusive() - Method in class org.hornetq.core.config.DivertConfiguration
-
- isExclusive() - Method in class org.hornetq.core.management.impl.DivertControlImpl
-
- isExclusive() - Method in interface org.hornetq.core.postoffice.Binding
-
- isExclusive() - Method in class org.hornetq.core.postoffice.impl.DivertBinding
-
- isExclusive() - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- isExclusive() - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- isExclusive() - Method in interface org.hornetq.core.server.Divert
-
- isExclusive() - Method in class org.hornetq.core.server.impl.DivertImpl
-
- isExclusive() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- isExists() - Method in class org.hornetq.core.server.BindingQueryResult
-
- isFailBackRequest() - Method in class org.hornetq.core.protocol.core.impl.wireformat.BackupRegistrationMessage
-
- isFailoverOnServerShutdown() - Method in interface org.hornetq.core.config.Configuration
-
Should we notify any clients on close that they should failover.
- isFailoverOnServerShutdown() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isFailoverOnServerShutdown() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isFileDeploymentEnabled() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether this server will use files to configure and deploy its resources.
- isFileDeploymentEnabled() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isFinalMessage() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationLiveIsStoppingMessage
-
The first message is sent to turn-off the quorumManager, which in some cases would trigger a
faster fail-over than what would be correct.
- isForwardWhenNoConsumers() - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- isForwardWhenNoConsumers() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- isHA() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- isHA() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- isHighAcceptPriority(ServerMessage) - Method in interface org.hornetq.core.postoffice.Binding
-
- isHighAcceptPriority(ServerMessage) - Method in class org.hornetq.core.postoffice.impl.DivertBinding
-
- isHighAcceptPriority(ServerMessage) - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- isHighAcceptPriority(ServerMessage) - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- isInternalQueue() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- isInternalQueue() - Method in interface org.hornetq.core.server.Queue
-
We can't send stuff to DLQ on queues used on clustered-bridge-communication
- isJMXManagementEnabled() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether this server is manageable using JMX or not.
- isJMXManagementEnabled() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isJournalSyncNonTransactional() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether the journal is synchronized when receiving non-transactional data.
- isJournalSyncNonTransactional() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isJournalSyncNonTransactional() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isJournalSyncTransactional() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether the journal is synchronized when receiving transactional data.
- isJournalSyncTransactional() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isJournalSyncTransactional() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isLargeMessage() - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl
-
- isLargeMessage() - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- isLastValueQueue() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- isLive() - Method in class org.hornetq.core.paging.cursor.impl.LivePageCacheImpl
-
- isLive() - Method in interface org.hornetq.core.paging.cursor.PageCache
-
- isLive() - Method in class org.hornetq.core.paging.impl.Page
-
- isLiveLocked() - Method in class org.hornetq.core.server.impl.FileLockNodeManager
-
- isLogJournalWriteRate() - Method in interface org.hornetq.core.config.Configuration
-
- isLogJournalWriteRate() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isMaskPassword() - Method in interface org.hornetq.core.config.Configuration
-
If passwords are masked.
- isMaskPassword() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isMemoryLow() - Method in class org.hornetq.core.server.MemoryManager
-
- isMessageCounterEnabled() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether message counter is enabled for this server.
- isMessageCounterEnabled() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isMessageCounterEnabled() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isNodeActive(String) - Method in interface org.hornetq.core.server.cluster.ClusterConnection
-
- isNodeActive(String) - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- isPaged() - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- isPaged() - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- isPaged() - Method in interface org.hornetq.core.server.MessageReference
-
- isPaging() - Method in class org.hornetq.core.management.impl.AddressControlImpl
-
- isPaging() - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- isPaging() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- isPaging() - Method in interface org.hornetq.core.paging.PagingStore
-
- isPaused() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- isPaused() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- isPaused() - Method in interface org.hornetq.core.server.Queue
-
- isPersistDeliveryCountBeforeDelivery() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether delivery count is persisted before messages are delivered to the consumers.
- isPersistDeliveryCountBeforeDelivery() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isPersistDeliveryCountBeforeDelivery() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isPersistenceEnabled() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether this server is using persistence and store data.
- isPersistenceEnabled() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isPersistenceEnabled() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isPersistent() - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- isPersistIDCache() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether message ID cache is persisted.
- isPersistIDCache() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isPersistIDCache() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isPlainCoreBridge() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- isPlainCoreBridge() - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionBridge
-
- isProtocol(byte[]) - Method in interface org.hornetq.spi.core.protocol.ProtocolManager
-
- isQueueBinding() - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- isReliable() - Method in class org.hornetq.core.remoting.impl.invm.InVMConnectorFactory
-
- isRemoteBackupUpToDate() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
Whether a remote backup server was in sync with its live server.
- isReplicated() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- isResolveProtocols() - Method in interface org.hornetq.core.config.Configuration
-
- isResolveProtocols() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isRollback() - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- isRollback() - Method in interface org.hornetq.core.paging.PageTransactionInfo
-
- isRollback() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationCommitMessage
-
- isRunSyncSpeedTest() - Method in interface org.hornetq.core.config.Configuration
-
- isRunSyncSpeedTest() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isSecurityEnabled() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether security is enabled for this server.
- isSecurityEnabled() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isSecurityEnabled() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isSendToDLAOnNoRoute() - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- isServerMessage() - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- isServerToFailBack() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage
-
- isSharedStore() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether this server shares its data store with a corresponding live or backup server.
- isSharedStore() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isSharedStore() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isStarted() - Method in class org.hornetq.core.deployers.impl.FileDeploymentManager
-
- isStarted() - Method in class org.hornetq.core.deployers.impl.XmlDeployer
-
- isStarted() - Method in class org.hornetq.core.management.impl.AcceptorControlImpl
-
- isStarted() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- isStarted() - Method in class org.hornetq.core.management.impl.BroadcastGroupControlImpl
-
- isStarted() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- isStarted() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- isStarted() - Method in class org.hornetq.core.paging.impl.PagingManagerImpl
-
- isStarted() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- isStarted() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- isStarted() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- isStarted() - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- isStarted() - Method in class org.hornetq.core.remoting.impl.invm.InVMAcceptor
-
- isStarted() - Method in class org.hornetq.core.remoting.impl.invm.InVMConnector
-
- isStarted() - Method in class org.hornetq.core.remoting.impl.netty.NettyAcceptor
-
- isStarted() - Method in class org.hornetq.core.remoting.server.impl.RemotingServiceImpl
-
- isStarted() - Method in interface org.hornetq.core.remoting.server.RemotingService
-
- isStarted() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- isStarted() - Method in class org.hornetq.core.replication.ReplicationEndpoint
-
- isStarted() - Method in class org.hornetq.core.replication.ReplicationManager
-
- isStarted() - Method in class org.hornetq.core.server.cluster.BackupManager
-
- isStarted() - Method in class org.hornetq.core.server.cluster.ClusterManager
-
- isStarted() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- isStarted() - Method in class org.hornetq.core.server.cluster.impl.BroadcastGroupImpl
-
- isStarted() - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- isStarted() - Method in class org.hornetq.core.server.group.impl.LocalGroupingHandler
-
- isStarted() - Method in class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- isStarted() - Method in class org.hornetq.core.server.impl.ConnectorsService
-
- isStarted() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- isStarted() - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- isStarted() - Method in class org.hornetq.core.server.MemoryManager
-
- isStarted() - Method in class org.hornetq.core.server.NodeManager
-
- isStarted() - Method in class org.hornetq.core.transaction.impl.ResourceManagerImpl
-
- isStarted() - Method in class org.hornetq.spi.core.security.HornetQSecurityManagerImpl
-
- isStarted() - Method in class org.hornetq.spi.core.security.JAASSecurityManager
-
- isSynchronizationFinished() - Method in class org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage
-
- isSynchronizing() - Method in class org.hornetq.core.replication.ReplicationManager
-
- isTemporary() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- isTemporary() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- isTemporary() - Method in interface org.hornetq.core.server.Queue
-
- isUnsecurable() - Method in class org.hornetq.core.remoting.impl.invm.InVMAcceptor
-
we are InVM so allow unsecure connections
- isUnsecurable() - Method in class org.hornetq.core.remoting.impl.netty.NettyAcceptor
-
only InVM acceptors should allow this
- isUnsecurable() - Method in interface org.hornetq.spi.core.remoting.Acceptor
-
Whether this acceptor allows insecure connections.
- isUseDuplicateDetection() - Method in class org.hornetq.core.config.BridgeConfiguration
-
- isUseDuplicateDetection() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- isValidateAIO() - Method in class org.hornetq.core.deployers.impl.FileConfigurationParser
-
- isWildcardRoutingEnabled() - Method in interface org.hornetq.core.config.Configuration
-
Returns whether wildcard routing is supported by this server.
- isWildcardRoutingEnabled() - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- isWildcardRoutingEnabled() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- iterator() - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- iterator() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- iterator() - Method in interface org.hornetq.core.server.Queue
-
- reacknowledge(Transaction, MessageReference) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- reacknowledge(Transaction, MessageReference) - Method in interface org.hornetq.core.server.Queue
-
- read(StorageManager) - Method in class org.hornetq.core.paging.impl.Page
-
- readLock() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- readLock() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- readLock() - Method in interface org.hornetq.core.persistence.StorageManager
-
Read lock the StorageManager.
- readNodeId() - Method in class org.hornetq.core.server.impl.FileLockNodeManager
-
- readNodeId() - Method in class org.hornetq.core.server.NodeManager
-
- readUnLock() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- readUnLock() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- readUnLock() - Method in interface org.hornetq.core.persistence.StorageManager
-
Unlock the manager.
- readyForWriting(boolean) - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- REAPER_PERIOD_PROP_NAME - Static variable in class org.hornetq.core.server.group.impl.GroupingHandlerConfiguration
-
- reattachRequestFailed(String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- receive(Proposal, int) - Method in interface org.hornetq.core.server.group.GroupingHandler
-
- receive(Proposal, int) - Method in class org.hornetq.core.server.group.impl.LocalGroupingHandler
-
- receive(Proposal, int) - Method in class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- receiveConsumerCredits(long, int) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- receiveConsumerCredits(long, int) - Method in interface org.hornetq.core.server.ServerSession
-
- receiveCredits(int) - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- receiveCredits(int) - Method in interface org.hornetq.core.server.ServerConsumer
-
- recods - Variable in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PageUpdateTXEncoding
-
- recoverAddressSettings() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- recoverAddressSettings() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- recoverAddressSettings() - Method in interface org.hornetq.core.persistence.StorageManager
-
- recoverPendingPageCounters(List<PageCountPending>) - Method in interface org.hornetq.core.server.impl.JournalLoader
-
- recoverPendingPageCounters(List<PageCountPending>) - Method in class org.hornetq.core.server.impl.PostOfficeJournalLoader
-
This method will recover the counters after failures making sure the page counter doesn't get out of sync
- recoverPersistedRoles() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- recoverPersistedRoles() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- recoverPersistedRoles() - Method in interface org.hornetq.core.persistence.StorageManager
-
- redeliver(PagePosition) - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
To be used on redeliveries
- redeploy(URI) - Method in interface org.hornetq.core.deployers.Deployer
-
Redeploys a URL if changed
- redeploy(URI) - Method in class org.hornetq.core.deployers.impl.XmlDeployer
-
Redeploys a URL if changed
- redistribute(ServerMessage, Queue, RoutingContext) - Method in interface org.hornetq.core.postoffice.Bindings
-
- redistribute(ServerMessage, Queue, RoutingContext) - Method in class org.hornetq.core.postoffice.impl.BindingsImpl
-
- redistribute(ServerMessage, Queue, Transaction) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
The redistribution can't process the route right away as we may be dealing with a large message which will need to be processed on a different thread
- redistribute(ServerMessage, Queue, Transaction) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- Redistributor - Class in org.hornetq.core.server.cluster.impl
-
A Redistributor
- Redistributor(Queue, StorageManager, PostOffice, Executor, int) - Constructor for class org.hornetq.core.server.cluster.impl.Redistributor
-
- REDISTRIBUTOR_BATCH_SIZE - Static variable in class org.hornetq.core.server.impl.QueueImpl
-
- refAdded(MessageReference) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- refEncoding - Variable in class org.hornetq.core.persistence.impl.journal.DescribeJournal.ReferenceDescribe
-
- refEncoding - Variable in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.AckDescribe
-
- RefEncoding() - Constructor for class org.hornetq.core.persistence.impl.journal.JournalStorageManager.RefEncoding
-
- RefEncoding(long) - Constructor for class org.hornetq.core.persistence.impl.journal.JournalStorageManager.RefEncoding
-
- ReferenceDescribe(JournalStorageManager.RefEncoding) - Constructor for class org.hornetq.core.persistence.impl.journal.DescribeJournal.ReferenceDescribe
-
- referenceHandled() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- referenceHandled() - Method in interface org.hornetq.core.server.Queue
-
- refRemoved(MessageReference) - Method in class org.hornetq.core.server.impl.LastValueQueue
-
- refRemoved(MessageReference) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- REFS_OPERATION - Static variable in class org.hornetq.core.transaction.TransactionPropertyIndexes
-
- RefsOperation() - Constructor for class org.hornetq.core.server.impl.QueueImpl.RefsOperation
-
- registerAcceptor(int, InVMAcceptor) - Method in class org.hornetq.core.remoting.impl.invm.InVMRegistry
-
- registerAcceptor(Acceptor, TransportConfiguration) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- registerAcceptor(Acceptor, TransportConfiguration) - Method in interface org.hornetq.core.server.management.ManagementService
-
- registerActivateCallback(ActivateCallback) - Method in interface org.hornetq.core.server.HornetQServer
-
- registerActivateCallback(ActivateCallback) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- registerAddress(SimpleString) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- registerAddress(SimpleString) - Method in interface org.hornetq.core.server.management.ManagementService
-
- registerBridge(Bridge, BridgeConfiguration) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- registerBridge(Bridge, BridgeConfiguration) - Method in interface org.hornetq.core.server.management.ManagementService
-
- registerBroadcastGroup(BroadcastGroup, BroadcastGroupConfiguration) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- registerBroadcastGroup(BroadcastGroup, BroadcastGroupConfiguration) - Method in interface org.hornetq.core.server.management.ManagementService
-
- registerCluster(ClusterConnection, ClusterConnectionConfiguration) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- registerCluster(ClusterConnection, ClusterConnectionConfiguration) - Method in interface org.hornetq.core.server.management.ManagementService
-
- registerDeployer(Deployer) - Method in interface org.hornetq.core.deployers.DeploymentManager
-
registers a deployable object which will handle the deployment of URL's
- registerDeployer(Deployer) - Method in class org.hornetq.core.deployers.impl.FileDeploymentManager
-
registers a Deployer object which will handle the deployment of URL's
- registerDivert(Divert, DivertConfiguration) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- registerDivert(Divert, DivertConfiguration) - Method in interface org.hornetq.core.server.management.ManagementService
-
- registerInJMX(ObjectName, Object) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- registerInJMX(ObjectName, Object) - Method in interface org.hornetq.core.server.management.ManagementService
-
- registerInRegistry(String, Object) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- registerInRegistry(String, Object) - Method in interface org.hornetq.core.server.management.ManagementService
-
- registerJournal(byte, Journal) - Method in class org.hornetq.core.replication.ReplicationEndpoint
-
- registerKeepAliveHandler(HttpAcceptorHandler) - Method in class org.hornetq.core.remoting.impl.netty.HttpKeepAliveRunnable
-
- registerListener(HierarchicalRepositoryChangeListener) - Method in interface org.hornetq.core.settings.HierarchicalRepository
-
register a listener to listen for changes in the repository
- registerListener(HierarchicalRepositoryChangeListener) - Method in class org.hornetq.core.settings.impl.HierarchicalObjectRepository
-
- registerMessageCounter(String, MessageCounter) - Method in class org.hornetq.core.messagecounter.impl.MessageCounterManagerImpl
-
- registerMessageCounter(String, MessageCounter) - Method in interface org.hornetq.core.messagecounter.MessageCounterManager
-
- registerQueue(Queue, SimpleString, StorageManager) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- registerQueue(Queue, SimpleString, StorageManager) - Method in interface org.hornetq.core.server.management.ManagementService
-
- registerServer(PostOffice, StorageManager, Configuration, HierarchicalRepository<AddressSettings>, HierarchicalRepository<Set<Role>>, ResourceManager, RemotingService, HornetQServer, QueueFactory, ScheduledExecutorService, PagingManager, boolean) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- registerServer(PostOffice, StorageManager, Configuration, HierarchicalRepository<AddressSettings>, HierarchicalRepository<Set<Role>>, ResourceManager, RemotingService, HornetQServer, QueueFactory, ScheduledExecutorService, PagingManager, boolean) - Method in interface org.hornetq.core.server.management.ManagementService
-
- registry - Variable in class org.hornetq.core.registry.MapBindingRegistry
-
- releaseBackup() - Method in class org.hornetq.core.server.impl.FileLockNodeManager
-
- releaseBackup() - Method in class org.hornetq.core.server.NodeManager
-
- releaseResources() - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl
-
- releaseResources() - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageInSync
-
- releaseResources() - Method in interface org.hornetq.core.replication.ReplicatedLargeMessage
-
- releaseResources() - Method in interface org.hornetq.core.server.LargeServerMessage
-
Close the files if opened
- reload(MessageReference) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- reload(MessageReference) - Method in interface org.hornetq.core.server.Queue
-
- reloadACK(PagePosition) - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- reloadPageCompletion(PagePosition) - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- reloadPageInfo(long) - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- reloadPreparedACK(Transaction, PagePosition) - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
To be used to avoid a redelivery of a prepared ACK after load
- reloadStores() - Method in class org.hornetq.core.paging.impl.PagingManagerImpl
-
- reloadStores(HierarchicalRepository<AddressSettings>) - Method in class org.hornetq.core.paging.impl.PagingStoreFactoryNIO
-
- reloadStores() - Method in interface org.hornetq.core.paging.PagingManager
-
Reload previously created PagingStores into memory
- reloadStores(HierarchicalRepository<AddressSettings>) - Method in interface org.hornetq.core.paging.PagingStoreFactory
-
- reloadUpdate(StorageManager, PagingManager, Transaction, int) - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- reloadUpdate(StorageManager, PagingManager, Transaction, int) - Method in interface org.hornetq.core.paging.PageTransactionInfo
-
- REMOTE_QUEUE_INDEX - Static variable in enum org.hornetq.core.postoffice.BindingType
-
- remoteFailOver(ReplicationLiveIsStoppingMessage.LiveStopping) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- remoteGroupCoordinatorsNotStarted() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- RemoteGroupingHandler - Class in org.hornetq.core.server.group.impl
-
A remote Grouping handler.
- RemoteGroupingHandler(ExecutorFactory, ManagementService, SimpleString, SimpleString, long, long) - Constructor for class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- RemoteGroupingHandler(ManagementService, SimpleString, SimpleString, long, long) - Constructor for class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- remoteQueueAlreadyBoundOnClusterConnection(Object, SimpleString) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- RemoteQueueBinding - Interface in org.hornetq.core.server.cluster
-
A RemoteQueueBinding
- RemoteQueueBindingImpl - Class in org.hornetq.core.server.cluster.impl
-
A RemoteQueueBindingImpl
- RemoteQueueBindingImpl(long, SimpleString, SimpleString, SimpleString, Long, SimpleString, Queue, SimpleString, int) - Constructor for class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- RemotingService - Interface in org.hornetq.core.remoting.server
-
- RemotingServiceImpl - Class in org.hornetq.core.remoting.server.impl
-
- RemotingServiceImpl(ClusterManager, Configuration, HornetQServer, ManagementService, ScheduledExecutorService, List<ProtocolManagerFactory>, Executor) - Constructor for class org.hornetq.core.remoting.server.impl.RemotingServiceImpl
-
- remove(SimpleString, SimpleString) - Method in interface org.hornetq.core.server.group.GroupingHandler
-
- remove(SimpleString, SimpleString, int) - Method in interface org.hornetq.core.server.group.GroupingHandler
-
- remove(SimpleString, SimpleString, int) - Method in class org.hornetq.core.server.group.impl.LocalGroupingHandler
-
- remove(SimpleString, SimpleString) - Method in class org.hornetq.core.server.group.impl.LocalGroupingHandler
-
- remove(SimpleString, SimpleString) - Method in class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- remove(SimpleString, SimpleString, int) - Method in class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- removeAddressSettings(String) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- removeBinding(SimpleString, Transaction) - Method in interface org.hornetq.core.postoffice.AddressManager
-
This will use a Transaction as we need to confirm the queue was removed
- removeBinding(Binding) - Method in interface org.hornetq.core.postoffice.Bindings
-
- removeBinding(Binding) - Method in class org.hornetq.core.postoffice.impl.BindingsImpl
-
- removeBinding(SimpleString, Transaction) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- removeBinding(SimpleString, Transaction) - Method in class org.hornetq.core.postoffice.impl.SimpleAddressManager
-
- removeBinding(SimpleString, Transaction) - Method in class org.hornetq.core.postoffice.impl.WildcardAddressManager
-
If the address is a wild card then the binding will be removed from the actual mappings for any linked address.
- removeBinding(SimpleString, Transaction) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- removeBindingInternal(SimpleString, SimpleString) - Method in class org.hornetq.core.postoffice.impl.SimpleAddressManager
-
- removeClusterLocator(ServerLocatorInternal) - Method in class org.hornetq.core.server.cluster.ClusterManager
-
- removeClusterTopologyListener(ClusterTopologyListener) - Method in interface org.hornetq.core.server.cluster.ClusterConnection
-
- removeClusterTopologyListener(ClusterTopologyListener) - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- removeConnection(Object) - Method in class org.hornetq.core.remoting.server.impl.RemotingServiceImpl
-
- removeConnection(Object) - Method in interface org.hornetq.core.remoting.server.RemotingService
-
Remove a connection from the connections held by the remoting service.
- removeConnector(TransportConfiguration) - Method in interface org.hornetq.core.server.cluster.BroadcastGroup
-
- removeConnector(TransportConfiguration) - Method in class org.hornetq.core.server.cluster.impl.BroadcastGroupImpl
-
- removeConsumer(SimpleString) - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- removeConsumer(SimpleString) - Method in interface org.hornetq.core.server.cluster.RemoteQueueBinding
-
- removeConsumer(Consumer) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- removeConsumer(long) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- removeConsumer(Consumer) - Method in interface org.hornetq.core.server.Queue
-
- removeConsumer(long) - Method in interface org.hornetq.core.server.ServerSession
-
- removeHandler(String) - Method in interface org.hornetq.spi.core.protocol.ProtocolManager
-
- removeHeuristicCompletion(Xid) - Method in class org.hornetq.core.transaction.impl.ResourceManagerImpl
-
- removeHeuristicCompletion(Xid) - Method in interface org.hornetq.core.transaction.ResourceManager
-
- removeIncomingInterceptor(Interceptor) - Method in class org.hornetq.core.remoting.server.impl.RemotingServiceImpl
-
- removeIncomingInterceptor(Interceptor) - Method in interface org.hornetq.core.remoting.server.RemotingService
-
- removeItself() - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- removeItself() - Method in interface org.hornetq.core.server.ServerConsumer
-
This method is just to remove itself from Queues.
- removeLinkedAddress(Address) - Method in interface org.hornetq.core.postoffice.Address
-
- removeLinkedAddress(Address) - Method in class org.hornetq.core.postoffice.impl.AddressImpl
-
- removeMapping(SimpleString, Bindings) - Method in class org.hornetq.core.postoffice.impl.SimpleAddressManager
-
- removeMatch(String) - Method in interface org.hornetq.core.settings.HierarchicalRepository
-
remove a match from the repository
- removeMatch(String) - Method in class org.hornetq.core.settings.impl.HierarchicalObjectRepository
-
remove a match from the repository
- removeMessage(long) - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- removeMessages(String) - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- removeMessages(int, String) - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- removeNotificationListener(NotificationListener, NotificationFilter, Object) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- removeNotificationListener(NotificationListener) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- removeNotificationListener(NotificationListener) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- removeOutgoingInterceptor(Interceptor) - Method in class org.hornetq.core.remoting.server.impl.RemotingServiceImpl
-
- removeOutgoingInterceptor(Interceptor) - Method in interface org.hornetq.core.remoting.server.RemotingService
-
- removeProtocolManagerFactory(ProtocolManagerFactory) - Method in interface org.hornetq.core.server.HornetQServer
-
- removeProtocolManagerFactory(ProtocolManagerFactory) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- removeReadyListener(ReadyListener) - Method in class org.hornetq.core.protocol.core.impl.CoreSessionCallback
-
- removeReadyListener(ReadyListener) - Method in class org.hornetq.core.remoting.impl.invm.InVMConnection
-
- removeReadyListener(ReadyListener) - Method in interface org.hornetq.spi.core.protocol.SessionCallback
-
- removeReferenceByID(long) - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- removeReferenceByID(long) - Method in interface org.hornetq.core.server.ServerConsumer
-
- removeReferenceWithID(long) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- removeReferenceWithID(long) - Method in class org.hornetq.core.server.impl.ScheduledDeliveryHandlerImpl
-
- removeReferenceWithID(long) - Method in interface org.hornetq.core.server.Queue
-
- removeReferenceWithID(long) - Method in interface org.hornetq.core.server.ScheduledDeliveryHandler
-
- removeRole(String, String) - Method in interface org.hornetq.spi.core.security.HornetQSecurityManager
-
removes a role from a user
- removeRole(String, String) - Method in class org.hornetq.spi.core.security.HornetQSecurityManagerImpl
-
- removeRole(String, String) - Method in class org.hornetq.spi.core.security.JAASSecurityManager
-
- removeSecuritySettings(String) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- removeSession(String) - Method in interface org.hornetq.core.server.HornetQServer
-
- removeSession(String) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- removeTransaction(long) - Method in class org.hornetq.core.paging.impl.PagingManagerImpl
-
- removeTransaction(long) - Method in interface org.hornetq.core.paging.PagingManager
-
- removeTransaction(Xid) - Method in class org.hornetq.core.transaction.impl.ResourceManagerImpl
-
- removeTransaction(Xid) - Method in interface org.hornetq.core.transaction.ResourceManager
-
- removeUser(String) - Method in interface org.hornetq.spi.core.security.HornetQSecurityManager
-
removes a user and any roles they may have.
- removeUser(String) - Method in class org.hornetq.spi.core.security.HornetQSecurityManagerImpl
-
- removeUser(String) - Method in class org.hornetq.spi.core.security.JAASSecurityManager
-
- removingBadConsumer(Throwable, Consumer, MessageReference) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- replaceQueueFactory(QueueFactory) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
For tests only, don't use this method as it's not part of the API
- replaceQueueName(SimpleString) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PersistentQueueBindingEncoding
-
- replaceQueueName(SimpleString) - Method in interface org.hornetq.core.persistence.QueueBindingInfo
-
used to rename the queue in case of a duplication during load time
- replacingIncompleteLargeMessage(Long) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- replicatedBackup - Variable in class org.hornetq.core.server.NodeManager
-
- ReplicatedJournal - Class in org.hornetq.core.replication
-
Used by the JournalStorageManager
to replicate journal calls.
- ReplicatedJournal(byte, Journal, ReplicationManager) - Constructor for class org.hornetq.core.replication.ReplicatedJournal
-
- ReplicatedLargeMessage - Interface in org.hornetq.core.replication
-
- ReplicationAddMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
A ReplicationAddMessage
- ReplicationAddMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddMessage
-
- ReplicationAddMessage(byte, ReplicationManager.ADD_OPERATION_TYPE, long, byte, EncodingSupport) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddMessage
-
- ReplicationAddTXMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
A ReplicationAddMessage
- ReplicationAddTXMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddTXMessage
-
- ReplicationAddTXMessage(byte, ReplicationManager.ADD_OPERATION_TYPE, long, long, byte, EncodingSupport) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationAddTXMessage
-
- replicationBackupUpToDate() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- ReplicationCommitMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
A ReplicationAddMessage
- ReplicationCommitMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationCommitMessage
-
- ReplicationCommitMessage(byte, boolean, long) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationCommitMessage
-
- ReplicationDeleteMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
A ReplicationDeleteMessage
- ReplicationDeleteMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationDeleteMessage
-
- ReplicationDeleteMessage(byte, long) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationDeleteMessage
-
- ReplicationDeleteTXMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
A ReplicationAddMessage
- ReplicationDeleteTXMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationDeleteTXMessage
-
- ReplicationDeleteTXMessage(byte, long, long, EncodingSupport) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationDeleteTXMessage
-
- replicationDone() - Method in class org.hornetq.core.persistence.impl.journal.OperationContextImpl
-
- replicationDone() - Method in interface org.hornetq.core.persistence.OperationContext
-
- ReplicationEndpoint - Class in org.hornetq.core.replication
-
Handles all the synchronization necessary for replication on the backup side (that is the
backup's side of the "remote backup" use case).
- ReplicationEndpoint(HornetQServerImpl, IOCriticalErrorListener, boolean) - Constructor for class org.hornetq.core.replication.ReplicationEndpoint
-
- ReplicationEndpoint.JournalSyncFile - Class in org.hornetq.core.replication
-
- ReplicationLargeMessageBeginMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
A ReplicationLargeMessageBeingMessage
- ReplicationLargeMessageBeginMessage(long) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageBeginMessage
-
- ReplicationLargeMessageBeginMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageBeginMessage
-
- ReplicationLargeMessageEndMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
A ReplicationLargemessageEndMessage
- ReplicationLargeMessageEndMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageEndMessage
-
- ReplicationLargeMessageEndMessage(long) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageEndMessage
-
- ReplicationLargeMessageWriteMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
A ReplicationLargeMessageWriteMessage
- ReplicationLargeMessageWriteMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageWriteMessage
-
- ReplicationLargeMessageWriteMessage(long, byte[]) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationLargeMessageWriteMessage
-
- replicationLineUp() - Method in class org.hornetq.core.persistence.impl.journal.OperationContextImpl
-
- replicationLineUp() - Method in interface org.hornetq.core.persistence.OperationContext
-
- ReplicationLiveIsStoppingMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
Message indicating that the live is stopping (a scheduled stop).
- ReplicationLiveIsStoppingMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationLiveIsStoppingMessage
-
- ReplicationLiveIsStoppingMessage(ReplicationLiveIsStoppingMessage.LiveStopping) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationLiveIsStoppingMessage
-
- ReplicationLiveIsStoppingMessage.LiveStopping - Enum in org.hornetq.core.protocol.core.impl.wireformat
-
- ReplicationManager - Class in org.hornetq.core.replication
-
Manages replication tasks on the live server (that is the live server side of a "remote backup"
use case).
- ReplicationManager(CoreRemotingConnection, ExecutorFactory) - Constructor for class org.hornetq.core.replication.ReplicationManager
-
- ReplicationManager.ADD_OPERATION_TYPE - Enum in org.hornetq.core.replication
-
- ReplicationPageEventMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
A ReplicationPageWrite
- ReplicationPageEventMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPageEventMessage
-
- ReplicationPageEventMessage(SimpleString, int, boolean) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPageEventMessage
-
- ReplicationPageWriteMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
A ReplicationPageWrite
- ReplicationPageWriteMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPageWriteMessage
-
- ReplicationPageWriteMessage(PagedMessage, int) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPageWriteMessage
-
- ReplicationPrepareMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
- ReplicationPrepareMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPrepareMessage
-
- ReplicationPrepareMessage(byte, long, EncodingSupport) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationPrepareMessage
-
- ReplicationResponseMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
- ReplicationResponseMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationResponseMessage
-
- replicationStartProblem(Exception) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- ReplicationStartSyncMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
This message may signal start or end of the replication synchronization.
- ReplicationStartSyncMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage
-
- ReplicationStartSyncMessage(List<Long>) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage
-
- ReplicationStartSyncMessage(String) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage
-
- ReplicationStartSyncMessage(JournalFile[], JournalStorageManager.JournalContent, String, boolean) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage
-
- ReplicationStartSyncMessage.SyncDataType - Enum in org.hornetq.core.protocol.core.impl.wireformat
-
- replicationStopOnBackupFail(Exception) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- replicationStopOnBackupShutdown() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- ReplicationSyncFileMessage - Class in org.hornetq.core.protocol.core.impl.wireformat
-
Message is used to sync SequentialFile
s to a backup server.
- ReplicationSyncFileMessage() - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationSyncFileMessage
-
- ReplicationSyncFileMessage(JournalStorageManager.JournalContent, SimpleString, long, int, ByteBuffer) - Constructor for class org.hornetq.core.protocol.core.impl.wireformat.ReplicationSyncFileMessage
-
- ReplicationSyncFileMessage.FileType - Enum in org.hornetq.core.protocol.core.impl.wireformat
-
- replicationSyncFinished() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- replicationSyncPreserveOldFiles() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- replicationTooManyJournals() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- replicationUnhandledDataType() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- replicationUnhandledError(Exception) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- replicationUnhandledFileType(ReplicationSyncFileMessage.FileType) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- requestProducerCredits(SimpleString, int) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- requestProducerCredits(SimpleString, int) - Method in interface org.hornetq.core.server.ServerSession
-
- reroute(ServerMessage, Queue, Transaction) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- reroute(ServerMessage, Queue, Transaction) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- reschedule(long) - Method in class org.hornetq.core.messagecounter.impl.MessageCounterManagerImpl
-
- reschedule(long) - Method in interface org.hornetq.core.messagecounter.MessageCounterManager
-
- resendPending() - Method in interface org.hornetq.core.server.group.GroupingHandler
-
- resendPending() - Method in class org.hornetq.core.server.group.impl.LocalGroupingHandler
-
- resendPending() - Method in class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- reset() - Method in interface org.hornetq.core.server.cluster.MessageFlowRecord
-
- reset() - Method in class org.hornetq.core.server.impl.QuorumManager
-
- resetAllCounterHistories() - Method in class org.hornetq.core.messagecounter.impl.MessageCounterManagerImpl
-
- resetAllCounterHistories() - Method in interface org.hornetq.core.messagecounter.MessageCounterManager
-
- resetAllCounters() - Method in class org.hornetq.core.messagecounter.impl.MessageCounterManagerImpl
-
- resetAllCounters() - Method in interface org.hornetq.core.messagecounter.MessageCounterManager
-
- resetAllIterators() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- resetAllIterators() - Method in interface org.hornetq.core.server.Queue
-
- resetAllMessageCounterHistories() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- resetAllMessageCounters() - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- resetCounter() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
- resetFailures() - Static method in class org.hornetq.core.remoting.impl.invm.InVMConnector
-
- resetHistory() - Method in class org.hornetq.core.messagecounter.MessageCounter
-
- resetMessageCounter() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- resetMessagesAdded() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- resetMessagesAdded() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- resetMessagesAdded() - Method in interface org.hornetq.core.server.Queue
-
- ResourceManager - Interface in org.hornetq.core.transaction
-
A ResourceManager
- ResourceManagerImpl - Class in org.hornetq.core.transaction.impl
-
A ResourceManagerImpl
- ResourceManagerImpl(int, long, ScheduledExecutorService) - Constructor for class org.hornetq.core.transaction.impl.ResourceManagerImpl
-
- Response - Class in org.hornetq.core.server.group.impl
-
A response to a proposal
- Response(SimpleString, SimpleString) - Constructor for class org.hornetq.core.server.group.impl.Response
-
- Response(SimpleString, SimpleString, SimpleString) - Constructor for class org.hornetq.core.server.group.impl.Response
-
- restartingReplicatedBackupAfterFailback() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- resume() - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- resume() - Method in interface org.hornetq.core.server.cluster.Bridge
-
- resume() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- resume() - Method in class org.hornetq.core.server.impl.QueueImpl
-
- resume() - Method in interface org.hornetq.core.server.Queue
-
Resumes the delivery of message for the queue.
- resume() - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- resume() - Method in interface org.hornetq.core.transaction.Transaction
-
- resumeCleanup() - Method in class org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl
-
- resumeCleanup() - Method in interface org.hornetq.core.paging.cursor.PageCursorProvider
-
- resumeCleanup() - Method in class org.hornetq.core.paging.impl.PagingManagerImpl
-
- resumeCleanup() - Method in interface org.hornetq.core.paging.PagingManager
-
- rolePermissionConfigurationError(String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- rollback() - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- rollback() - Method in interface org.hornetq.core.paging.PageTransactionInfo
-
- rollback(long) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- rollback(long) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- rollback(long) - Method in interface org.hornetq.core.persistence.StorageManager
-
- rollback(boolean) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- rollback(boolean) - Method in interface org.hornetq.core.server.ServerSession
-
- rollback() - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- rollback() - Method in interface org.hornetq.core.transaction.Transaction
-
- rollbackBindings(long) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- rollbackBindings(long) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- rollbackBindings(long) - Method in interface org.hornetq.core.persistence.StorageManager
-
- rollbackPreparedTransaction(String) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- route(ServerMessage, RoutingContext) - Method in interface org.hornetq.core.postoffice.Binding
-
- route(ServerMessage, RoutingContext) - Method in interface org.hornetq.core.postoffice.Bindings
-
- route(ServerMessage, RoutingContext) - Method in class org.hornetq.core.postoffice.impl.BindingsImpl
-
- route(ServerMessage, RoutingContext) - Method in class org.hornetq.core.postoffice.impl.DivertBinding
-
- route(ServerMessage, RoutingContext) - Method in class org.hornetq.core.postoffice.impl.LocalQueueBinding
-
- route(ServerMessage, boolean) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- route(ServerMessage, Transaction, boolean) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- route(ServerMessage, Transaction, boolean, boolean) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- route(ServerMessage, RoutingContext, boolean) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- route(ServerMessage, RoutingContext, boolean, boolean) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- route(ServerMessage, boolean) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- route(ServerMessage, Transaction, boolean) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- route(ServerMessage, Transaction, boolean, boolean) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- route(ServerMessage, RoutingContext, boolean) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- route(ServerMessage, RoutingContext, boolean, boolean) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- route(ServerMessage, RoutingContext) - Method in interface org.hornetq.core.server.Bindable
-
- route(ServerMessage, RoutingContext) - Method in class org.hornetq.core.server.cluster.impl.RemoteQueueBindingImpl
-
- route(ServerMessage, RoutingContext) - Method in class org.hornetq.core.server.impl.DivertImpl
-
- route(ServerMessage, RoutingContext) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- RouteContextList - Interface in org.hornetq.core.server
-
This is a simple datatype containing the list of a routing context
- routeNameIsNull() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- RoutingContext - Interface in org.hornetq.core.server
-
A RoutingContext
- RoutingContextImpl - Class in org.hornetq.core.server.impl
-
A RoutingContextImpl
- RoutingContextImpl(Transaction) - Constructor for class org.hornetq.core.server.impl.RoutingContextImpl
-
- run() - Method in class org.hornetq.core.deployers.impl.FileDeploymentManager
-
called by the ExecutorService every n seconds
- run() - Method in class org.hornetq.core.remoting.impl.netty.HttpKeepAliveRunnable
-
- run() - Method in class org.hornetq.core.server.cluster.impl.BroadcastGroupImpl
-
- runDirectJournalBlast() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- runSyncSpeedTest - Variable in class org.hornetq.core.config.impl.ConfigurationImpl
-
- scheduleCleanup() - Method in class org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl
-
- scheduleCleanup() - Method in interface org.hornetq.core.paging.cursor.PageCursorProvider
-
- scheduleCleanupCheck() - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- scheduleCompactAndBlock(int) - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- ScheduledDeliveryEncoding() - Constructor for class org.hornetq.core.persistence.impl.journal.JournalStorageManager.ScheduledDeliveryEncoding
-
- ScheduledDeliveryHandler - Interface in org.hornetq.core.server
-
- ScheduledDeliveryHandlerImpl - Class in org.hornetq.core.server.impl
-
Handles scheduling deliveries to a queue at the correct time.
- ScheduledDeliveryHandlerImpl(ScheduledExecutorService) - Constructor for class org.hornetq.core.server.impl.ScheduledDeliveryHandlerImpl
-
- scheduledExecutor - Variable in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- scheduledExecutor - Variable in class org.hornetq.core.server.impl.QueueFactoryImpl
-
- scheduleRetryConnect() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- scheduleRetryConnectFixedTimeout(long) - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- SECURITY_ELEMENT_NAME - Static variable in class org.hornetq.core.deployers.impl.FileConfigurationParser
-
- SECURITY_RECORD - Static variable in class org.hornetq.core.persistence.impl.journal.JournalRecordIds
-
- SecurityDeployer - Class in org.hornetq.core.deployers.impl
-
Deploys the security settings into a security repository and adds them to the security store.
- SecurityDeployer(DeploymentManager, HierarchicalRepository<Set<Role>>) - Constructor for class org.hornetq.core.deployers.impl.SecurityDeployer
-
- securityManager - Variable in class org.hornetq.core.server.embedded.EmbeddedHornetQ
-
- SecurityStore - Interface in org.hornetq.core.security
-
- SecurityStoreImpl - Class in org.hornetq.core.security.impl
-
The HornetQ SecurityStore implementation
- SecurityStoreImpl(HierarchicalRepository<Set<Role>>, HornetQSecurityManager, long, boolean, String, String, NotificationService) - Constructor for class org.hornetq.core.security.impl.SecurityStoreImpl
-
- send(ServerMessage, boolean) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- send(ServerMessage, boolean) - Method in interface org.hornetq.core.server.ServerSession
-
- sendAcknowledged(Message) - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- sendContinuations(int, long, byte[], boolean) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- sendContinuations(int, long, byte[], boolean) - Method in interface org.hornetq.core.server.ServerSession
-
- sendLarge(MessageInternal) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- sendLarge(MessageInternal) - Method in interface org.hornetq.core.server.ServerSession
-
- sendLargeMessage(ServerMessage, long, long, int) - Method in class org.hornetq.core.protocol.core.impl.CoreSessionCallback
-
- sendLargeMessage(ServerMessage, long, long, int) - Method in interface org.hornetq.spi.core.protocol.SessionCallback
-
- sendLargeMessageContinuation(long, byte[], boolean, boolean) - Method in class org.hornetq.core.protocol.core.impl.CoreSessionCallback
-
- sendLargeMessageContinuation(long, byte[], boolean, boolean) - Method in interface org.hornetq.spi.core.protocol.SessionCallback
-
- sendLargeMessageIdListMessage(Map<Long, Pair<String, Long>>) - Method in class org.hornetq.core.replication.ReplicationManager
-
Reserves several LargeMessage IDs in the backup.
- sendLiveIsStopping(ReplicationLiveIsStoppingMessage.LiveStopping) - Method in class org.hornetq.core.replication.ReplicationManager
-
Notifies the backup that the live server is stopping.
- sendMessage(ServerMessage, long, int) - Method in class org.hornetq.core.protocol.core.impl.CoreSessionCallback
-
- sendMessage(ServerMessage, long, int) - Method in interface org.hornetq.spi.core.protocol.SessionCallback
-
- sendMessagesToDeadLetterAddress(String) - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- sendMessagesToDeadLetterAddress(Filter) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- sendMessagesToDeadLetterAddress(Filter) - Method in interface org.hornetq.core.server.Queue
-
- sendMessageToDeadLetterAddress(long) - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- sendMessageToDeadLetterAddress(long) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- sendMessageToDeadLetterAddress(long) - Method in interface org.hornetq.core.server.Queue
-
- sendNotification(Notification) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- sendPages(ReplicationManager, Collection<Integer>) - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- sendPages(ReplicationManager, Collection<Integer>) - Method in interface org.hornetq.core.paging.PagingStore
-
- sendProducerCreditsFailMessage(int, SimpleString) - Method in class org.hornetq.core.protocol.core.impl.CoreSessionCallback
-
- sendProducerCreditsFailMessage(int, SimpleString) - Method in interface org.hornetq.spi.core.protocol.SessionCallback
-
- sendProducerCreditsMessage(int, SimpleString) - Method in class org.hornetq.core.protocol.core.impl.CoreSessionCallback
-
- sendProducerCreditsMessage(int, SimpleString) - Method in interface org.hornetq.spi.core.protocol.SessionCallback
-
- sendProposalResponse(Response, int) - Method in interface org.hornetq.core.server.group.GroupingHandler
-
- sendProposalResponse(Response, int) - Method in class org.hornetq.core.server.group.impl.LocalGroupingHandler
-
- sendProposalResponse(Response, int) - Method in class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- sendQueueInfoToQueue(String, String) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- sendQueueInfoToQueue(SimpleString, SimpleString) - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- sendQueueInfoToQueue(SimpleString, SimpleString) - Method in interface org.hornetq.core.postoffice.PostOffice
-
- sendStartSyncMessage(JournalFile[], JournalStorageManager.JournalContent, String, boolean) - Method in class org.hornetq.core.replication.ReplicationManager
-
Reserve the following fileIDs in the backup server.
- sendSynchronizationDone(String) - Method in class org.hornetq.core.replication.ReplicationManager
-
Informs backup that data synchronization is done.
- sendUnproposal(SimpleString, SimpleString, int) - Method in class org.hornetq.core.server.group.impl.GroupHandlingAbstract
-
- serialVersionUID - Static variable in class org.hornetq.core.server.group.impl.GroupingHandlerConfiguration
-
- SERVER_ID_PROP_NAME - Static variable in class org.hornetq.core.remoting.impl.invm.TransportConstants
-
- ServerConnectionLifeCycleListener - Interface in org.hornetq.spi.core.remoting
-
- ServerConsumer - Interface in org.hornetq.core.server
-
A ServerConsumer
- ServerConsumerImpl - Class in org.hornetq.core.server.impl
-
Concrete implementation of a ClientConsumer.
- ServerConsumerImpl(long, ServerSession, QueueBinding, Filter, boolean, boolean, StorageManager, SessionCallback, boolean, boolean, ManagementService) - Constructor for class org.hornetq.core.server.impl.ServerConsumerImpl
-
- ServerConsumerImpl(long, ServerSession, QueueBinding, Filter, boolean, boolean, StorageManager, SessionCallback, boolean, boolean, ManagementService, boolean, Integer) - Constructor for class org.hornetq.core.server.impl.ServerConsumerImpl
-
- serverDescribe(String, String) - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- serverDisconnected() - Method in interface org.hornetq.core.server.cluster.MessageFlowRecord
-
- serverFinalisedWIthoutBeingSTopped() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- ServerInfo - Class in org.hornetq.core.server.impl
-
A ServerInfo
- ServerInfo(HornetQServer, PagingManager) - Constructor for class org.hornetq.core.server.impl.ServerInfo
-
- serverIsLive() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- serverIsLive(String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- serverIsStopped() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- serverLocator - Variable in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- ServerMessage - Interface in org.hornetq.core.server
-
A ServerMessage
- ServerMessageImpl - Class in org.hornetq.core.server.impl
-
A ServerMessageImpl
- ServerMessageImpl() - Constructor for class org.hornetq.core.server.impl.ServerMessageImpl
-
- ServerMessageImpl(long, int) - Constructor for class org.hornetq.core.server.impl.ServerMessageImpl
-
- ServerMessageImpl(ServerMessageImpl) - Constructor for class org.hornetq.core.server.impl.ServerMessageImpl
-
- ServerMessageImpl(ServerMessageImpl, TypedProperties) - Constructor for class org.hornetq.core.server.impl.ServerMessageImpl
-
- serverNotBackupServer() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- serverNotStarted() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- ServerPacketDecoder - Class in org.hornetq.core.protocol
-
- ServerPacketDecoder() - Constructor for class org.hornetq.core.protocol.ServerPacketDecoder
-
- serverRestartWarning() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- serverRestartWarning(Exception) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- ServerSession - Interface in org.hornetq.core.server
-
A ServerSession
- ServerSessionImpl - Class in org.hornetq.core.server.impl
-
Server side Session implementation
- ServerSessionImpl(String, String, String, int, boolean, boolean, boolean, boolean, boolean, RemotingConnection, StorageManager, PostOffice, ResourceManager, SecurityStore, ManagementService, HornetQServer, SimpleString, SimpleString, SessionCallback, OperationContext) - Constructor for class org.hornetq.core.server.impl.ServerSessionImpl
-
- ServerSessionPacketHandler - Class in org.hornetq.core.protocol.core
-
A ServerSessionPacketHandler
- ServerSessionPacketHandler(ServerSession, StorageManager, Channel) - Constructor for class org.hornetq.core.protocol.core.ServerSessionPacketHandler
-
- serverStarted(String, SimpleString, String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- serverStarting(String, Configuration) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- serverStopped(String, SimpleString) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- session - Variable in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- SessionCallback - Interface in org.hornetq.spi.core.protocol
-
A SessionCallback
- sessionNotFailedOver() - Method in interface org.hornetq.core.server.HornetQMessageBundle
-
- SET_SCHEDULED_DELIVERY_TIME - Static variable in class org.hornetq.core.persistence.impl.journal.JournalRecordIds
-
- setAcceptorConfigurations(Set<TransportConfiguration>) - Method in interface org.hornetq.core.config.Configuration
-
Sets the acceptors configured for this server.
- setAcceptorConfigurations(Set<TransportConfiguration>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setAddress(String) - Method in class org.hornetq.core.config.CoreQueueConfiguration
-
- setAddress(String) - Method in class org.hornetq.core.config.DivertConfiguration
-
- setAddressesSettings(Map<String, AddressSettings>) - Method in interface org.hornetq.core.config.Configuration
-
- setAddressesSettings(Map<String, AddressSettings>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setAddressFullMessagePolicy(AddressFullMessagePolicy) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setAllowAutoFailBack(boolean) - Method in interface org.hornetq.core.config.Configuration
-
whether a backup will automatically stop when a live server is restarting (i.e.
- setAllowAutoFailBack(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setBackup(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether this server is a backup or not.
- setBackup(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setBackupGroupName(String) - Method in interface org.hornetq.core.config.Configuration
-
Used to configure groups of live/backup servers.
- setBackupGroupName(String) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setBindingsDirectory(String) - Method in interface org.hornetq.core.config.Configuration
-
Sets the file system directory used to store bindings.
- setBindingsDirectory(String) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setBridgeConfigurations(List<BridgeConfiguration>) - Method in interface org.hornetq.core.config.Configuration
-
Sets the bridges configured for this server.
- setBridgeConfigurations(List<BridgeConfiguration>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setBroadcastGroupConfigurations(List<BroadcastGroupConfiguration>) - Method in interface org.hornetq.core.config.Configuration
-
Sets the broadcast groups configured for this server.
- setBroadcastGroupConfigurations(List<BroadcastGroupConfiguration>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setCacheMaxSize(int) - Method in class org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl
-
- setCacheMaxSize(int) - Method in interface org.hornetq.core.paging.cursor.PageCursorProvider
-
- setCallbackHandler(CallbackHandler) - Method in class org.hornetq.spi.core.security.JAASSecurityManager
-
- setCallFailoverTimeout(long) - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- setCallTimeout(long) - Method in class org.hornetq.core.config.BridgeConfiguration
-
At this point this is only changed on testcases
The bridge shouldn't be sending blocking anyways
- setCallTimeout(long) - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- setChannel(Channel) - Method in class org.hornetq.core.replication.ReplicationEndpoint
-
- setCheckForLiveServer(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether to check if the cluster already has a (live) node with our node-ID.
- setCheckForLiveServer(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setClientFailureCheckPeriod(long) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setClientFailureCheckPeriod(long) - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- setClusterConfigurations(List<ClusterConnectionConfiguration>) - Method in interface org.hornetq.core.config.Configuration
-
Sets the cluster connections configured for this server.
- setClusterConfigurations(List<ClusterConnectionConfiguration>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setClusterPassword(String) - Method in interface org.hornetq.core.config.Configuration
-
Sets the cluster password for this server.
- setClusterPassword(String) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setClusterUser(String) - Method in interface org.hornetq.core.config.Configuration
-
Sets the cluster user for this server.
- setClusterUser(String) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setCommitted(boolean) - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- setCommitted(boolean) - Method in interface org.hornetq.core.paging.PageTransactionInfo
-
- setConfigFileNames(String[]) - Method in class org.hornetq.core.deployers.impl.XmlDeployer
-
- setConfigResourcePath(String) - Method in class org.hornetq.core.server.embedded.EmbeddedHornetQ
-
Classpath resource for hornetq server config.
- setConfiguration(Configuration) - Method in class org.hornetq.core.server.embedded.EmbeddedHornetQ
-
Set this object if you are not using file-based configuration.
- setConfiguration(Configuration) - Method in class org.hornetq.spi.core.security.JAASSecurityManager
-
- setConfigurationName(String) - Method in class org.hornetq.spi.core.security.JAASSecurityManager
-
- setConfigurationUrl(String) - Method in class org.hornetq.core.config.impl.FileConfiguration
-
- setConfirmationWindowSize(int) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setConnectionTTL(long) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setConnectionTTL(long) - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- setConnectionTTLOverride(long) - Method in interface org.hornetq.core.config.Configuration
-
Sets the connection time to live.
- setConnectionTTLOverride(long) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setConnectorConfigurations(Map<String, TransportConfiguration>) - Method in interface org.hornetq.core.config.Configuration
-
Sets the connectors configured for this server.
- setConnectorConfigurations(Map<String, TransportConfiguration>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setConnectorServiceConfigurations(List<ConnectorServiceConfiguration>) - Method in interface org.hornetq.core.config.Configuration
-
- setConnectorServiceConfigurations(List<ConnectorServiceConfiguration>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setConsumerId(Long) - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- setConsumerId(Long) - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- setConsumerId(Long) - Method in interface org.hornetq.core.server.MessageReference
-
- setConsumersRefCount(HornetQServer) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- setConsumersRefCount(HornetQServer) - Method in interface org.hornetq.core.server.Queue
-
This will set a reference counter for every consumer present on the queue.
- setContainsPersistent() - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- setContainsPersistent() - Method in interface org.hornetq.core.transaction.Transaction
-
- setContext(OperationContext) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- setContext(OperationContext) - Static method in class org.hornetq.core.persistence.impl.journal.OperationContextImpl
-
- setContext(OperationContext) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- setContext(OperationContext) - Method in interface org.hornetq.core.persistence.StorageManager
-
Set the context back to the thread
- setContext(Object) - Method in class org.hornetq.core.registry.JndiBindingRegistry
-
- setContext(Object) - Method in class org.hornetq.core.registry.MapBindingRegistry
-
- setContext(Object) - Method in interface org.hornetq.spi.core.naming.BindingRegistry
-
- setCreateBindingsDir(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether the bindings directory is created on this server startup.
- setCreateBindingsDir(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setCreateJournalDir(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether the journal directory is created on this server startup.
- setCreateJournalDir(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setDeadLetterAddress(String) - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- setDeadLetterAddress(SimpleString) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setDefault(T) - Method in interface org.hornetq.core.settings.HierarchicalRepository
-
set the default value to fallback to if none found
- setDefault(T) - Method in class org.hornetq.core.settings.impl.HierarchicalObjectRepository
-
set the default value to fallback to if none found
- setDefaultHornetQPrincipal(HornetQPrincipal) - Method in class org.hornetq.core.remoting.impl.invm.InVMAcceptor
-
- setDefaultHornetQPrincipal(HornetQPrincipal) - Method in class org.hornetq.core.remoting.impl.netty.NettyAcceptor
-
not allowed
- setDefaultHornetQPrincipal(HornetQPrincipal) - Method in interface org.hornetq.spi.core.remoting.Acceptor
-
Set the default security Principal to be used when no user/pass are defined, only for InVM
- setDefaultUser(String) - Method in interface org.hornetq.spi.core.security.HornetQSecurityManager
-
- setDefaultUser(String) - Method in class org.hornetq.spi.core.security.HornetQSecurityManagerImpl
-
- setDefaultUser(String) - Method in class org.hornetq.spi.core.security.JAASSecurityManager
-
- setDeletePages(boolean) - Method in class org.hornetq.core.replication.ReplicationEndpoint
-
Used on tests only.
- setDeliveryCount(int) - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- setDeliveryCount(int) - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- setDeliveryCount(int) - Method in interface org.hornetq.core.server.MessageReference
-
- setDiscoveryGroupConfigurations(Map<String, DiscoveryGroupConfiguration>) - Method in interface org.hornetq.core.config.Configuration
-
Sets the discovery groups configured for this server.
- setDiscoveryGroupConfigurations(Map<String, DiscoveryGroupConfiguration>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setDiscoveryGroupName(String) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setDivertConfigurations(List<DivertConfiguration>) - Method in interface org.hornetq.core.config.Configuration
-
Sets the diverts configured for this server.
- setDivertConfigurations(List<DivertConfiguration>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setDuplicateDetection(boolean) - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- setDurable(boolean) - Method in class org.hornetq.core.config.CoreQueueConfiguration
-
- setDurable(boolean) - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageInSync
-
- setDurable(boolean) - Method in interface org.hornetq.core.replication.ReplicatedLargeMessage
-
- setEnabledAsyncConnectionExecution(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether code coming from connection is executed asynchronously or not.
- setEnabledAsyncConnectionExecution(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setExclusive(boolean) - Method in class org.hornetq.core.config.DivertConfiguration
-
- setExecutor(Executor) - Method in class org.hornetq.core.replication.ReplicationEndpoint
-
- setExpiryAddress(String) - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- setExpiryAddress(SimpleString) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setExpiryDelay(Long) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setFailbackDelay(long) - Method in interface org.hornetq.core.config.Configuration
-
Sets the fail-back delay.
- setFailbackDelay(long) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setFailoverOnServerShutdown(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether to allow clients to failover on server shutdown.
- setFailoverOnServerShutdown(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setFailoverOnServerShutdown(boolean) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- setFileDeployerScanPeriod(long) - Method in interface org.hornetq.core.config.Configuration
-
Sets the period to scan configuration files used by deployment.
- setFileDeployerScanPeriod(long) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setFileDeploymentEnabled(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether this server will use files to configure and deploy its resources.
- setFileDeploymentEnabled(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setFilterString(String) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setFilterString(String) - Method in class org.hornetq.core.config.CoreQueueConfiguration
-
- setFilterString(String) - Method in class org.hornetq.core.config.DivertConfiguration
-
- setFilterStrings(List<SimpleString>) - Method in class org.hornetq.core.postoffice.QueueInfo
-
- setFlushEnabled(boolean) - Static method in class org.hornetq.core.remoting.impl.invm.InVMConnection
-
- setForwardingAddress(String) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setForwardingAddress(String) - Method in class org.hornetq.core.config.DivertConfiguration
-
- setForwardWhenNoConsumers(boolean) - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- setFuture(Future<?>) - Method in class org.hornetq.core.remoting.impl.netty.HttpKeepAliveRunnable
-
- setGroupingHandler(GroupingHandler) - Method in interface org.hornetq.core.server.HornetQServer
-
- setGroupingHandler(GroupingHandler) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- setGroupingHandlerConfiguration(GroupingHandlerConfiguration) - Method in interface org.hornetq.core.config.Configuration
-
Sets the grouping handler configured for this server.
- setGroupingHandlerConfiguration(GroupingHandlerConfiguration) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setHA(boolean) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setID(long) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PageCountPendingImpl
-
- setId(long) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager.PersistentQueueBindingEncoding
-
- setId(long) - Method in class org.hornetq.core.server.group.impl.GroupBinding
-
- setIDCacheSize(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the size of the cache for pre-creating message IDs.
- setIDCacheSize(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setIdentity(String) - Method in interface org.hornetq.core.server.HornetQServer
-
Sets the server identity.
- setIdentity(String) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- setIgnoreRedeliveryCheck() - Method in class org.hornetq.core.server.impl.QueueImpl.RefsOperation
-
- setIncomingInterceptorClassNames(List<String>) - Method in interface org.hornetq.core.config.Configuration
-
Sets the list of interceptors classes used by this server for incoming messages (i.e.
- setIncomingInterceptorClassNames(List<String>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setInitialConnectAttempts(int) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setInitialConnectAttempts(int) - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- setInterceptorClassNames(List<String>) - Method in interface org.hornetq.core.config.Configuration
-
- setInterceptorClassNames(List<String>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
Deprecated.
- setInternalQueue(boolean) - Method in class org.hornetq.core.server.impl.QueueImpl
-
- setInternalQueue(boolean) - Method in interface org.hornetq.core.server.Queue
-
- setJMXDomain(String) - Method in interface org.hornetq.core.config.Configuration
-
Sets the domain used by JMX MBeans (provided JMX management is enabled).
- setJMXDomain(String) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJMXManagementEnabled(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether this server is manageable using JMX or not.
- setJMXManagementEnabled(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalBufferSize_AIO(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the buffer size (in bytes) for AIO.
- setJournalBufferSize_AIO(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalBufferSize_NIO(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the buffer size (in bytes) for NIO.
- setJournalBufferSize_NIO(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalBufferTimeout_AIO(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the timeout (in nanoseconds) used to flush buffers in the AIO queue.
- setJournalBufferTimeout_AIO(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalBufferTimeout_NIO(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the timeout (in nanoseconds) used to flush buffers in the NIO.
- setJournalBufferTimeout_NIO(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalCompactMinFiles(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the minimal number of journal files before compacting.
- setJournalCompactMinFiles(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalCompactPercentage(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the percentage of live data before compacting the journal.
- setJournalCompactPercentage(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalDirectory(String) - Method in interface org.hornetq.core.config.Configuration
-
Sets the file system directory used to store journal log.
- setJournalDirectory(String) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalFileSize(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the size (in bytes) of each journal files.
- setJournalFileSize(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalMaxIO_AIO(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the maximum number of write requests that can be in the AIO queue at any given time.
- setJournalMaxIO_AIO(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalMaxIO_NIO(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the maximum number of write requests for NIO journal.
- setJournalMaxIO_NIO(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalMinFiles(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the number of journal files to pre-create.
- setJournalMinFiles(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalPerfBlastPages(int) - Method in interface org.hornetq.core.config.Configuration
-
- setJournalPerfBlastPages(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalSyncNonTransactional(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether the journal is synchronized when receiving non-transactional data.
- setJournalSyncNonTransactional(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalSyncTransactional(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether the journal is synchronized when receiving transactional data.
- setJournalSyncTransactional(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setJournalType(JournalType) - Method in interface org.hornetq.core.config.Configuration
-
Sets the type of journal used by this server (either NIO
or ASYNCIO
).
- setJournalType(JournalType) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setLargeMessagesDirectory(String) - Method in interface org.hornetq.core.config.Configuration
-
Sets the file system directory used to store large messages.
- setLargeMessagesDirectory(String) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setLastValueQueue(boolean) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setLiveCache(LivePageCache) - Method in class org.hornetq.core.paging.impl.Page
-
- setLiveID(String) - Method in class org.hornetq.core.server.impl.QuorumManager
-
- setLogJournalWriteRate(boolean) - Method in interface org.hornetq.core.config.Configuration
-
- setLogJournalWriteRate(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setManagementAddress(SimpleString) - Method in interface org.hornetq.core.config.Configuration
-
Sets the management address of this server.
- setManagementAddress(SimpleString) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setManagementNotificationAddress(SimpleString) - Method in interface org.hornetq.core.config.Configuration
-
Sets the management notification address of this server.
- setManagementNotificationAddress(SimpleString) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setMaskPassword(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets if passwords should be masked or not.
- setMaskPassword(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setMatch(String) - Method in class org.hornetq.core.settings.impl.Match
-
- setMaxDayCount(int) - Method in class org.hornetq.core.messagecounter.impl.MessageCounterManagerImpl
-
- setMaxDayCount(int) - Method in interface org.hornetq.core.messagecounter.MessageCounterManager
-
- setMaxDeliveryAttempts(int) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setMaxRedeliveryDelay(long) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setMaxRetryInterval(long) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setMaxRetryInterval(long) - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- setMaxSavedReplicatedJournalSize(int) - Method in interface org.hornetq.core.config.Configuration
-
How many backup journals to keep after failback occurs.
- setMaxSavedReplicatedJournalSize(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setMaxSizeBytes(long) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setMbeanServer(MBeanServer) - Method in class org.hornetq.core.server.embedded.EmbeddedHornetQ
-
Use this mbean server to register management beans.
- setMemoryMeasureInterval(long) - Method in interface org.hornetq.core.config.Configuration
-
- setMemoryMeasureInterval(long) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setMemoryWarningThreshold(int) - Method in interface org.hornetq.core.config.Configuration
-
- setMemoryWarningThreshold(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setMessageCounter(MessageCounter) - Method in class org.hornetq.core.management.impl.QueueControlImpl
-
- setMessageCounterEnabled(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether message counter is enabled for this server.
- setMessageCounterEnabled(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setMessageCounterHistoryDayLimit(int) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setMessageCounterMaxDayCount(int) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- setMessageCounterMaxDayHistory(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the maximum number of days kept in memory for message counter.
- setMessageCounterMaxDayHistory(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setMessageCounterSamplePeriod(long) - Method in interface org.hornetq.core.config.Configuration
-
Sets the sample period to take message counter snapshot.
- setMessageCounterSamplePeriod(long) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setMessageCounterSamplePeriod(long) - Method in class org.hornetq.core.management.impl.HornetQServerControlImpl
-
- setMessageExpiryScanPeriod(long) - Method in interface org.hornetq.core.config.Configuration
-
Sets the frequency (in milliseconds) to scan messages to detect which messages
have expired.
- setMessageExpiryScanPeriod(long) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setMessageExpiryThreadPriority(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the priority of the thread used to scan message expiration.
- setMessageExpiryThreadPriority(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setMessageID(long) - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageInSync
-
- setMessageID(long) - Method in interface org.hornetq.core.replication.ReplicatedLargeMessage
-
- setMessageID(long) - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- setMessageID(long) - Method in interface org.hornetq.core.server.ServerMessage
-
- setMessages(PagedMessage[]) - Method in class org.hornetq.core.paging.cursor.impl.LivePageCacheImpl
-
- setMessages(PagedMessage[]) - Method in interface org.hornetq.core.paging.cursor.PageCache
-
- setMinLargeMessageSize(int) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setMinLargeMessageSize(int) - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- setName(String) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setName(String) - Method in interface org.hornetq.core.config.Configuration
-
To be used on dependency management on the application server
- setName(String) - Method in class org.hornetq.core.config.CoreQueueConfiguration
-
- setName(String) - Method in class org.hornetq.core.config.DivertConfiguration
-
- setName(String) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setNodeGroupName(String) - Method in class org.hornetq.core.server.NodeManager
-
- setNodeID(String) - Method in class org.hornetq.core.server.NodeManager
-
Sets the nodeID.
- setNotificationService(NotificationService) - Method in class org.hornetq.core.remoting.impl.invm.InVMAcceptor
-
- setNotificationService(NotificationService) - Method in class org.hornetq.core.remoting.impl.netty.NettyAcceptor
-
- setNotificationService(NotificationService) - Method in interface org.hornetq.core.server.cluster.Bridge
-
- setNotificationService(NotificationService) - Method in interface org.hornetq.core.server.cluster.BroadcastGroup
-
- setNotificationService(NotificationService) - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- setNotificationService(NotificationService) - Method in class org.hornetq.core.server.cluster.impl.BroadcastGroupImpl
-
- setNotificationService(NotificationService) - Method in interface org.hornetq.spi.core.remoting.Acceptor
-
Set the notification service for this acceptor to use.
- setOriginalHeaders(ServerMessage, MessageReference, boolean) - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl
-
- setOriginalHeaders(ServerMessage, MessageReference, boolean) - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- setOriginalHeaders(ServerMessage, MessageReference, boolean) - Method in interface org.hornetq.core.server.ServerMessage
-
- setOutgoingInterceptorClassNames(List<String>) - Method in interface org.hornetq.core.config.Configuration
-
Sets the list of interceptors classes used by this server for outgoing messages (i.e.
- setOutgoingInterceptorClassNames(List<String>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setPageCacheMaxSize(int) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setPaged() - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl
-
- setPaged() - Method in interface org.hornetq.core.server.LargeServerMessage
-
We have to copy the large message content in case of DLQ and paged messages
For that we need to pre-mark the LargeMessage with a flag when it is paged
- setPageMaxConcurrentIO(int) - Method in interface org.hornetq.core.config.Configuration
-
The max number of concurrent reads allowed on paging.
- setPageMaxConcurrentIO(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setPageSizeBytes(long) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setPagingDirectory(String) - Method in interface org.hornetq.core.config.Configuration
-
Sets the file system directory used to store paging files.
- setPagingDirectory(String) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setPagingManager(PagingManager) - Method in class org.hornetq.core.paging.impl.PagingStoreFactoryNIO
-
- setPagingManager(PagingManager) - Method in interface org.hornetq.core.paging.PagingStoreFactory
-
- setPagingStore(PagingStore) - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- setPagingStore(PagingStore) - Method in interface org.hornetq.core.server.ServerMessage
-
- setPassword(String) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setPasswordCodec(String) - Method in interface org.hornetq.core.config.Configuration
-
The default password decoder
- setPasswordCodec(String) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setPendingRecordID(long) - Method in class org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl
-
- setPendingRecordID(long) - Method in interface org.hornetq.core.server.LargeServerMessage
-
- setPersistDeliveryCountBeforeDelivery(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether delivery count is persisted before messages are delivered to consumers.
- setPersistDeliveryCountBeforeDelivery(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setPersistedCount(int) - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- setPersistedCount(int) - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- setPersistedCount(int) - Method in interface org.hornetq.core.server.MessageReference
-
- setPersistenceEnabled(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether this server is using persistence and store data.
- setPersistenceEnabled(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setPersistent(boolean) - Method in class org.hornetq.core.paging.cursor.impl.PageSubscriptionCounterImpl
-
used on testing only
- setPersistIDCache(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether message ID cache is persisted.
- setPersistIDCache(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setPostOffice(PostOffice) - Method in class org.hornetq.core.server.impl.QueueFactoryImpl
-
- setPostOffice(PostOffice) - Method in interface org.hornetq.core.server.QueueFactory
-
This is required for delete-all-reference to work correctly with paging
- setQueue(Queue) - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- setQueueConfigurations(List<CoreQueueConfiguration>) - Method in interface org.hornetq.core.config.Configuration
-
Sets the queues configured for this server.
- setQueueConfigurations(List<CoreQueueConfiguration>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setQueueName(String) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setQuorumManager(QuorumManager) - Method in class org.hornetq.core.replication.ReplicationEndpoint
-
Sets the quorumManager used by the server in the replicationEndpoint.
- setReconnectAttempts(int) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setReconnectAttempts(int) - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- setReconnectAttemptsOnSameNode(int) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setRecordID(long) - Method in class org.hornetq.core.paging.cursor.impl.PagePositionImpl
-
- setRecordID(long) - Method in interface org.hornetq.core.paging.cursor.PagePosition
-
- setRecordID(long) - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- setRecordID(long) - Method in interface org.hornetq.core.paging.PageTransactionInfo
-
- setRedeliveryDelay(long) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setRedeliveryMultiplier(double) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setRedistributionDelay(long) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setRemoteBackupUpToDate() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- setReplicationClustername(String) - Method in interface org.hornetq.core.config.Configuration
-
Name of the cluster configuration to use for replication.
- setReplicationClustername(String) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setResolveProtocols(boolean) - Method in interface org.hornetq.core.config.Configuration
-
- setResolveProtocols(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setRetryInterval(long) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setRetryInterval(long) - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- setRetryIntervalMultiplier(double) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setRetryIntervalMultiplier(double) - Method in class org.hornetq.core.config.ClusterConnectionConfiguration
-
- setRouteWhenNoConsumers(boolean) - Method in interface org.hornetq.core.postoffice.Bindings
-
- setRouteWhenNoConsumers(boolean) - Method in class org.hornetq.core.postoffice.impl.BindingsImpl
-
- setRoutingName(String) - Method in class org.hornetq.core.config.DivertConfiguration
-
- setRunSyncSpeedTest(boolean) - Method in interface org.hornetq.core.config.Configuration
-
- setRunSyncSpeedTest(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setScheduledDeliveryTime(long) - Method in class org.hornetq.core.paging.cursor.PagedReferenceImpl
-
- setScheduledDeliveryTime(long) - Method in class org.hornetq.core.server.impl.MessageReferenceImpl
-
- setScheduledDeliveryTime(long) - Method in interface org.hornetq.core.server.MessageReference
-
- setScheduledThreadPoolMaxSize(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the maximum number of threads in the scheduled thread pool of this server.
- setScheduledThreadPoolMaxSize(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setSecurityEnabled(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether security is enabled for this server.
- setSecurityEnabled(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setSecurityInvalidationInterval(long) - Method in interface org.hornetq.core.config.Configuration
-
Sets the interval time (in milliseconds) to invalidate security credentials.
- setSecurityInvalidationInterval(long) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setSecurityManager(HornetQSecurityManager) - Method in class org.hornetq.core.server.embedded.EmbeddedHornetQ
-
Set the hornetq security manager.
- setSecurityRoles(Map<String, Set<Role>>) - Method in interface org.hornetq.core.config.Configuration
-
- setSecurityRoles(Map<String, Set<Role>>) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setSendToDLAOnNoRoute(boolean) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setServerDumpInterval(long) - Method in interface org.hornetq.core.config.Configuration
-
- setServerDumpInterval(long) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setSessionFactory(ClientSessionFactoryInternal) - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- setSessionFactory(ClientSessionFactoryInternal) - Method in class org.hornetq.core.server.impl.QuorumManager
-
- setSharedStore(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether this server shares its data store with a backup or live server.
- setSharedStore(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setSlowConsumerCheckPeriod(long) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setSlowConsumerPolicy(SlowConsumerPolicy) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setSlowConsumerThreshold(long) - Method in class org.hornetq.core.settings.impl.AddressSettings
-
- setStarted(boolean) - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- setStarted(boolean) - Method in interface org.hornetq.core.server.ServerConsumer
-
- setState(Transaction.State) - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- setState(Transaction.State) - Method in interface org.hornetq.core.transaction.Transaction
-
- setStaticConnectors(List<String>) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setStorageManager(StorageManager) - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- setStorageManager(StorageManager) - Method in interface org.hornetq.core.server.management.ManagementService
-
- setStoreId(long) - Method in class org.hornetq.core.persistence.config.PersistedAddressSetting
-
- setStoreId(long) - Method in class org.hornetq.core.persistence.config.PersistedRoles
-
- setThreadPoolMaxSize(int) - Method in interface org.hornetq.core.config.Configuration
-
Sets the maximum number of threads in the thread pool of this server.
- setThreadPoolMaxSize(int) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setTimeout(int) - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- setTimeout(int) - Method in interface org.hornetq.core.transaction.Transaction
-
- setTransaction(Transaction) - Method in class org.hornetq.core.server.impl.RoutingContextImpl
-
- setTransaction(Transaction) - Method in interface org.hornetq.core.server.RoutingContext
-
- setTransactionTimeout(long) - Method in interface org.hornetq.core.config.Configuration
-
Sets the timeout (in milliseconds) after which transactions is removed
from the resource manager after it was created.
- setTransactionTimeout(long) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setTransactionTimeoutScanPeriod(long) - Method in interface org.hornetq.core.config.Configuration
-
Sets the frequency (in milliseconds) to scan transactions to detect which transactions
have timed out.
- setTransactionTimeoutScanPeriod(long) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- setTransferring(boolean) - Method in class org.hornetq.core.server.impl.ServerConsumerImpl
-
- setTransferring(boolean) - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- setTransferring(boolean) - Method in interface org.hornetq.core.server.ServerConsumer
-
- setTransferring(boolean) - Method in interface org.hornetq.core.server.ServerSession
-
- setTransformerClassName(String) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setTransformerClassName(String) - Method in class org.hornetq.core.config.DivertConfiguration
-
- setUpServerLockFile() - Method in class org.hornetq.core.server.NodeManager
-
Ensures existence of persistent information about the server's nodeID.
- setUseDuplicateDetection(boolean) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setUser(String) - Method in class org.hornetq.core.config.BridgeConfiguration
-
- setUUID(UUID) - Method in class org.hornetq.core.server.NodeManager
-
- setValidateAIO(boolean) - Method in class org.hornetq.core.deployers.impl.FileConfigurationParser
-
- setValue(T) - Method in class org.hornetq.core.settings.impl.Match
-
- setWildcardRoutingEnabled(boolean) - Method in interface org.hornetq.core.config.Configuration
-
Sets whether wildcard routing is supported by this server.
- setWildcardRoutingEnabled(boolean) - Method in class org.hornetq.core.config.impl.ConfigurationImpl
-
- shutdown() - Method in class org.hornetq.core.remoting.impl.netty.HttpAcceptorHandler
-
- SimpleAddressManager - Class in org.hornetq.core.postoffice.impl
-
A simple address manager that maintains the addresses and bindings.
- SimpleAddressManager(BindingsFactory) - Constructor for class org.hornetq.core.postoffice.impl.SimpleAddressManager
-
- SimplePrincipal(String) - Constructor for class org.hornetq.spi.core.security.JAASSecurityManager.SimplePrincipal
-
- size() - Method in class org.hornetq.core.remoting.impl.invm.InVMRegistry
-
- size() - Method in interface org.hornetq.core.server.cluster.BroadcastGroup
-
- size() - Method in class org.hornetq.core.server.cluster.impl.BroadcastGroupImpl
-
- SIZE_RECORD - Static variable in class org.hornetq.core.paging.impl.Page
-
- SLOW_CONSUMER_POLICY_TYPE - Static variable in class org.hornetq.core.config.impl.Validators
-
- slowConsumerDetected(String, long, String, String, float, float) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- SlowConsumerPolicy - Enum in org.hornetq.core.settings.impl
-
A SlowConsumerPolicy
- start() - Method in class org.hornetq.core.config.impl.FileConfiguration
-
- start() - Method in class org.hornetq.core.deployers.impl.FileDeploymentManager
-
- start() - Method in class org.hornetq.core.deployers.impl.XmlDeployer
-
- start() - Method in class org.hornetq.core.management.impl.AcceptorControlImpl
-
- start() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- start() - Method in class org.hornetq.core.management.impl.BroadcastGroupControlImpl
-
- start() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- start() - Method in class org.hornetq.core.messagecounter.impl.MessageCounterManagerImpl
-
- start() - Method in interface org.hornetq.core.messagecounter.MessageCounterManager
-
- start() - Method in class org.hornetq.core.paging.impl.PagingManagerImpl
-
- start() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- start() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- start() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- start() - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- start() - Method in class org.hornetq.core.remoting.impl.invm.InVMAcceptor
-
- start() - Method in class org.hornetq.core.remoting.impl.invm.InVMConnector
-
- start() - Method in class org.hornetq.core.remoting.impl.netty.NettyAcceptor
-
- start() - Method in class org.hornetq.core.remoting.server.impl.RemotingServiceImpl
-
- start() - Method in interface org.hornetq.core.remoting.server.RemotingService
-
- start() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- start() - Method in class org.hornetq.core.replication.ReplicationEndpoint
-
- start() - Method in class org.hornetq.core.replication.ReplicationManager
-
- start() - Method in class org.hornetq.core.server.cluster.BackupManager
-
- start() - Method in class org.hornetq.core.server.cluster.ClusterManager
-
- start() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- start() - Method in class org.hornetq.core.server.cluster.impl.BroadcastGroupImpl
-
- start() - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- start() - Method in class org.hornetq.core.server.cluster.impl.Redistributor
-
- start() - Method in class org.hornetq.core.server.embedded.EmbeddedHornetQ
-
- start() - Method in class org.hornetq.core.server.group.impl.LocalGroupingHandler
-
- start() - Method in class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- start() - Method in class org.hornetq.core.server.impl.ConnectorsService
-
- start() - Method in class org.hornetq.core.server.impl.FileLockNodeManager
-
- start() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- start() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- start() - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- start() - Method in class org.hornetq.core.server.MemoryManager
-
- start() - Method in class org.hornetq.core.server.NodeManager
-
- start() - Method in interface org.hornetq.core.server.ServerSession
-
- start() - Method in class org.hornetq.core.transaction.impl.ResourceManagerImpl
-
- start() - Method in class org.hornetq.spi.core.security.HornetQSecurityManagerImpl
-
- start() - Method in class org.hornetq.spi.core.security.JAASSecurityManager
-
lifecycle method, needs to be called
- startAcceptors() - Method in class org.hornetq.core.remoting.server.impl.RemotingServiceImpl
-
- startAcceptors() - Method in interface org.hornetq.core.remoting.server.RemotingService
-
- startBackup() - Method in class org.hornetq.core.server.impl.FileLockNodeManager
-
- startBackup() - Method in class org.hornetq.core.server.NodeManager
-
- startBackupServers(Configuration, Map<String, HornetQServer>) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- startedNettyAcceptor(String, String, Integer) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- startExpiryScanner() - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
The expiry scanner can't be started until the whole server has been started other wise you may get races
- startExpiryScanner() - Method in interface org.hornetq.core.postoffice.PostOffice
-
- startLiveNode() - Method in class org.hornetq.core.server.impl.FileLockNodeManager
-
- startLiveNode() - Method in class org.hornetq.core.server.NodeManager
-
- startPaging() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- startPaging() - Method in interface org.hornetq.core.paging.PagingStore
-
- startReplication(ReplicationManager, PagingManager, String, boolean) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
Starts replication at the live-server side.
- startReplication(ReplicationManager, PagingManager, String, boolean) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- startReplication(ReplicationManager, PagingManager, String, boolean) - Method in interface org.hornetq.core.persistence.StorageManager
-
- startReplication(CoreRemotingConnection, ClusterConnection, Pair<TransportConfiguration, TransportConfiguration>, boolean) - Method in interface org.hornetq.core.server.HornetQServer
-
Starts replication.
- startReplication(CoreRemotingConnection, ClusterConnection, Pair<TransportConfiguration, TransportConfiguration>, boolean) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- stompBeginTX(String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- stompErrorTXExists(String) - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- stompTXAckNorSupported() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- stop() - Method in class org.hornetq.core.config.impl.FileConfiguration
-
- stop() - Method in class org.hornetq.core.deployers.impl.FileDeploymentManager
-
- stop() - Method in class org.hornetq.core.deployers.impl.XmlDeployer
-
- stop() - Method in class org.hornetq.core.management.impl.AcceptorControlImpl
-
- stop() - Method in class org.hornetq.core.management.impl.BridgeControlImpl
-
- stop() - Method in class org.hornetq.core.management.impl.BroadcastGroupControlImpl
-
- stop() - Method in class org.hornetq.core.management.impl.ClusterConnectionControlImpl
-
- stop() - Method in class org.hornetq.core.messagecounter.impl.MessageCounterManagerImpl
-
- stop() - Method in interface org.hornetq.core.messagecounter.MessageCounterManager
-
- stop() - Method in class org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl
-
- stop() - Method in interface org.hornetq.core.paging.cursor.PageCursorProvider
-
- stop() - Method in interface org.hornetq.core.paging.cursor.PageSubscription
-
- stop() - Method in class org.hornetq.core.paging.impl.PagingManagerImpl
-
- stop() - Method in class org.hornetq.core.paging.impl.PagingStoreFactoryNIO
-
- stop() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- stop() - Method in interface org.hornetq.core.paging.PagingStoreFactory
-
- stop() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- stop(boolean) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- stop() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- stop(boolean) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- stop(boolean) - Method in interface org.hornetq.core.persistence.StorageManager
-
- stop() - Method in class org.hornetq.core.postoffice.impl.PostOfficeImpl
-
- stop() - Method in class org.hornetq.core.remoting.impl.invm.InVMAcceptor
-
- stop() - Method in class org.hornetq.core.remoting.impl.netty.NettyAcceptor
-
- stop(boolean) - Method in class org.hornetq.core.remoting.server.impl.RemotingServiceImpl
-
- stop(boolean) - Method in interface org.hornetq.core.remoting.server.RemotingService
-
- stop() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- stop() - Method in class org.hornetq.core.replication.ReplicationEndpoint
-
- stop() - Method in class org.hornetq.core.replication.ReplicationManager
-
- stop() - Method in class org.hornetq.core.security.impl.SecurityStoreImpl
-
- stop() - Method in interface org.hornetq.core.security.SecurityStore
-
- stop() - Method in class org.hornetq.core.server.cluster.BackupManager
-
- stop() - Method in class org.hornetq.core.server.cluster.ClusterManager
-
- stop() - Method in class org.hornetq.core.server.cluster.impl.BridgeImpl
-
- stop() - Method in class org.hornetq.core.server.cluster.impl.BroadcastGroupImpl
-
- stop() - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- stop() - Method in class org.hornetq.core.server.cluster.impl.Redistributor
-
- stop() - Method in class org.hornetq.core.server.embedded.EmbeddedHornetQ
-
- stop() - Method in class org.hornetq.core.server.group.impl.LocalGroupingHandler
-
- stop() - Method in class org.hornetq.core.server.group.impl.RemoteGroupingHandler
-
- stop(boolean) - Method in interface org.hornetq.core.server.HornetQServer
-
- stop() - Method in class org.hornetq.core.server.impl.ConnectorsService
-
- stop() - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- stop(boolean) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
- stop() - Method in class org.hornetq.core.server.impl.ServerSessionImpl
-
- stop() - Method in class org.hornetq.core.server.management.impl.ManagementServiceImpl
-
- stop() - Method in class org.hornetq.core.server.MemoryManager
-
- stop() - Method in class org.hornetq.core.server.NodeManager
-
- stop() - Method in interface org.hornetq.core.server.ServerSession
-
- stop() - Method in class org.hornetq.core.transaction.impl.ResourceManagerImpl
-
- stop() - Method in class org.hornetq.spi.core.security.HornetQSecurityManagerImpl
-
- stop() - Method in class org.hornetq.spi.core.security.JAASSecurityManager
-
- stopBackup() - Method in class org.hornetq.core.server.NodeManager
-
- stopPaging() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- stopPaging() - Method in interface org.hornetq.core.paging.PagingStore
-
- stopReplicatedBackupAfterFailback() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- stopReplication() - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
Stops replication by resetting replication-related fields to their 'unreplicated' state.
- stopReplication() - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- stopReplication() - Method in interface org.hornetq.core.persistence.StorageManager
-
Stops the replication of data from the live to the backup.
- stopTheServer(boolean) - Method in class org.hornetq.core.server.impl.HornetQServerImpl
-
Stops the server in a different thread.
- storageManager - Variable in class org.hornetq.core.management.impl.AbstractControl
-
- StorageManager - Interface in org.hornetq.core.persistence
-
A StorageManager
- storageManager - Variable in class org.hornetq.core.server.impl.QueueFactoryImpl
-
- storageManager - Variable in class org.hornetq.core.transaction.impl.TransactionImpl
-
- StorageManager.LargeMessageExtension - Enum in org.hornetq.core.persistence
-
- store(StorageManager, PagingManager, Transaction) - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- store(StorageManager, PagingManager, Transaction) - Method in interface org.hornetq.core.paging.PageTransactionInfo
-
- storeAcknowledge(long, long) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeAcknowledge(long, long) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeAcknowledge(long, long) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storeAcknowledgeTransactional(long, long, long) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeAcknowledgeTransactional(long, long, long) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeAcknowledgeTransactional(long, long, long) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storeAddressSetting(PersistedAddressSetting) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeAddressSetting(PersistedAddressSetting) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeAddressSetting(PersistedAddressSetting) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storeBookmark(ArrayList<PageSubscription>, Page) - Method in class org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl
-
- storeCursorAcknowledge(long, PagePosition) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeCursorAcknowledge(long, PagePosition) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeCursorAcknowledge(long, PagePosition) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storeCursorAcknowledgeTransactional(long, long, PagePosition) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeCursorAcknowledgeTransactional(long, long, PagePosition) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeCursorAcknowledgeTransactional(long, long, PagePosition) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storeDuplicateID(SimpleString, byte[], long) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeDuplicateID(SimpleString, byte[], long) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeDuplicateID(SimpleString, byte[], long) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storeDuplicateIDTransactional(long, SimpleString, byte[], long) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeDuplicateIDTransactional(long, SimpleString, byte[], long) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeDuplicateIDTransactional(long, SimpleString, byte[], long) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storeHeuristicCompletion(Xid, boolean) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeHeuristicCompletion(Xid, boolean) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeHeuristicCompletion(Xid, boolean) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storeID(long, long) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeID(long, long) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeID(long, long) - Method in interface org.hornetq.core.persistence.StorageManager
-
Stores the given journalID in the bindingsJournal.
- storeIsPaging() - Method in class org.hornetq.core.server.impl.ServerMessageImpl
-
- storeIsPaging() - Method in interface org.hornetq.core.server.ServerMessage
-
- storeLineUp() - Method in class org.hornetq.core.persistence.impl.journal.OperationContextImpl
-
- storeMessage(ServerMessage) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeMessage(ServerMessage) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeMessage(ServerMessage) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storeMessageTransactional(long, ServerMessage) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeMessageTransactional(long, ServerMessage) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeMessageTransactional(long, ServerMessage) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storePageCompleteTransactional(long, long, PagePosition) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storePageCompleteTransactional(long, long, PagePosition) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storePageCompleteTransactional(long, long, PagePosition) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storePageCounter(long, long, long) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storePageCounter(long, long, long) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storePageCounter(long, long, long) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storePageCounterInc(long, long, int) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storePageCounterInc(long, int) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storePageCounterInc(long, long, int) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storePageCounterInc(long, int) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storePageCounterInc(long, long, int) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storePageCounterInc(long, int) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storePageTransaction(long, PageTransactionInfo) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storePageTransaction(long, PageTransactionInfo) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storePageTransaction(long, PageTransactionInfo) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storePendingCounter(long, long, int) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storePendingCounter(long, long, int) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storePendingCounter(long, long, int) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storePendingLargeMessage(long) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeReference(long, long, boolean) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeReference(long, long, boolean) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeReference(long, long, boolean) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storeReferenceTransactional(long, long, long) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeReferenceTransactional(long, long, long) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeReferenceTransactional(long, long, long) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storeSecurityRoles(PersistedRoles) - Method in class org.hornetq.core.persistence.impl.journal.JournalStorageManager
-
- storeSecurityRoles(PersistedRoles) - Method in class org.hornetq.core.persistence.impl.nullpm.NullStorageManager
-
- storeSecurityRoles(PersistedRoles) - Method in interface org.hornetq.core.persistence.StorageManager
-
- storeUpdate(StorageManager, PagingManager, Transaction) - Method in class org.hornetq.core.paging.impl.PageTransactionInfoImpl
-
- storeUpdate(StorageManager, PagingManager, Transaction) - Method in interface org.hornetq.core.paging.PageTransactionInfo
-
- suspend() - Method in class org.hornetq.core.transaction.impl.TransactionImpl
-
- suspend() - Method in interface org.hornetq.core.transaction.Transaction
-
- switchingNIO() - Method in interface org.hornetq.core.server.HornetQServerLogger
-
- sync() - Method in class org.hornetq.core.paging.impl.Page
-
- sync() - Method in class org.hornetq.core.paging.impl.PagingStoreImpl
-
- sync() - Method in interface org.hornetq.core.paging.PagingStore
-
Schedules sync to the file storage.
- synchronizationLock() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- synchronizationUnlock() - Method in class org.hornetq.core.replication.ReplicatedJournal
-
- syncJournalFile(JournalFile, JournalStorageManager.JournalContent) - Method in class org.hornetq.core.replication.ReplicationManager
-
Sends the whole content of the file to be duplicated.
- syncLargeMessageFile(SequentialFile, long, long) - Method in class org.hornetq.core.replication.ReplicationManager
-
- syncNonTransactional - Variable in class org.hornetq.core.paging.impl.PagingStoreFactoryNIO
-
- syncPages(SequentialFile, long, SimpleString) - Method in class org.hornetq.core.replication.ReplicationManager
-
- validate(String, Object) - Method in interface org.hornetq.core.config.impl.Validators.Validator
-
- validate(Node) - Method in class org.hornetq.core.deployers.impl.AddressSettingsDeployer
-
- validate(Node) - Method in class org.hornetq.core.deployers.impl.BasicUserCredentialsDeployer
-
- validate(Node) - Method in class org.hornetq.core.deployers.impl.QueueDeployer
-
- validate(Node) - Method in class org.hornetq.core.deployers.impl.SecurityDeployer
-
- validate(Node) - Method in class org.hornetq.core.deployers.impl.XmlDeployer
-
Validate the DOM
- validateUser(String, String) - Method in interface org.hornetq.spi.core.security.HornetQSecurityManager
-
is this a valid user.
- validateUser(String, String) - Method in class org.hornetq.spi.core.security.HornetQSecurityManagerImpl
-
- validateUser(String, String) - Method in class org.hornetq.spi.core.security.JAASSecurityManager
-
- validateUserAndRole(String, String, Set<Role>, CheckType) - Method in interface org.hornetq.spi.core.security.HornetQSecurityManager
-
is this a valid user and do they have the correct role
- validateUserAndRole(String, String, Set<Role>, CheckType) - Method in class org.hornetq.spi.core.security.HornetQSecurityManagerImpl
-
- validateUserAndRole(String, String, Set<Role>, CheckType) - Method in class org.hornetq.spi.core.security.JAASSecurityManager
-
- Validators - Class in org.hornetq.core.config.impl
-
A Validators.
- Validators() - Constructor for class org.hornetq.core.config.impl.Validators
-
- Validators.Validator - Interface in org.hornetq.core.config.impl
-
- valueOf(String) - Static method in enum org.hornetq.core.persistence.impl.journal.JournalStorageManager.JournalContent
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hornetq.core.persistence.StorageManager.LargeMessageExtension
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hornetq.core.postoffice.BindingType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hornetq.core.protocol.core.impl.wireformat.BackupReplicationStartFailedMessage.BackupRegistrationProblem
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hornetq.core.protocol.core.impl.wireformat.ReplicationLiveIsStoppingMessage.LiveStopping
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage.SyncDataType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hornetq.core.protocol.core.impl.wireformat.ReplicationSyncFileMessage.FileType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hornetq.core.replication.ReplicationManager.ADD_OPERATION_TYPE
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hornetq.core.security.CheckType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hornetq.core.server.group.impl.GroupingHandlerConfiguration.TYPE
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hornetq.core.server.HandleStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hornetq.core.server.JournalType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hornetq.core.settings.impl.SlowConsumerPolicy
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hornetq.core.transaction.Transaction.State
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.hornetq.core.persistence.impl.journal.JournalStorageManager.JournalContent
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hornetq.core.persistence.StorageManager.LargeMessageExtension
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hornetq.core.postoffice.BindingType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hornetq.core.protocol.core.impl.wireformat.BackupReplicationStartFailedMessage.BackupRegistrationProblem
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hornetq.core.protocol.core.impl.wireformat.ReplicationLiveIsStoppingMessage.LiveStopping
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hornetq.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage.SyncDataType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hornetq.core.protocol.core.impl.wireformat.ReplicationSyncFileMessage.FileType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hornetq.core.replication.ReplicationManager.ADD_OPERATION_TYPE
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hornetq.core.security.CheckType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hornetq.core.server.group.impl.GroupingHandlerConfiguration.TYPE
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hornetq.core.server.HandleStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hornetq.core.server.JournalType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Method in interface org.hornetq.core.settings.HierarchicalRepository
-
Return a list of Values being added
- values() - Method in class org.hornetq.core.settings.impl.HierarchicalObjectRepository
-
- values() - Static method in enum org.hornetq.core.settings.impl.SlowConsumerPolicy
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hornetq.core.transaction.Transaction.State
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- verify(String, String) - Method in interface org.hornetq.core.server.cluster.ClusterConnection
-
Verifies whether user and password match the ones configured for this ClusterConnection.
- verify(String, String) - Method in class org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
-
- verify(String) - Static method in class org.hornetq.core.settings.impl.Match
-
utility method to verify consistency of match