Index

A B C D E F G H I J K L M N O P Q R S T U V W X Y _ 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

abort() - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
abort() - Method in class com.swiftmq.impl.store.standard.StoreReadTransactionImpl
 
abort() - Method in class com.swiftmq.impl.store.standard.StoreTransactionImpl
 
abort(AsyncCompletionCallback) - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
abort(AsyncCompletionCallback) - Method in class com.swiftmq.impl.store.standard.StoreTransactionImpl
 
abort(AbortLogRecord) - Method in class com.swiftmq.impl.store.standard.recover.RecoveryManager
 
abort(XidImpl) - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
abort(XidImpl) - Method in class com.swiftmq.impl.store.standard.StoreReadTransactionImpl
 
abort(XidImpl) - Method in class com.swiftmq.impl.store.standard.StoreWriteTransactionImpl
 
ABORT - Static variable in class com.swiftmq.impl.store.standard.log.LogRecord
 
abortCurrentMessage() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
AbortLogRecord - Class in com.swiftmq.impl.store.standard.log
 
AbortLogRecord(long, Semaphore, List, CacheReleaseListener) - Constructor for class com.swiftmq.impl.store.standard.log.AbortLogRecord
 
AbortLogRecord(long, Semaphore, List, CacheReleaseListener, AsyncCompletionCallback) - Constructor for class com.swiftmq.impl.store.standard.log.AbortLogRecord
 
abortTransaction() - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
abortTransaction(AsyncCompletionCallback) - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
AbstractConstant<T extends AbstractConstant<T>> - Class in com.swiftmq.impl.mqtt.v311.netty.util
Base implementation of Constant.
AbstractConstant(int, String) - Constructor for class com.swiftmq.impl.mqtt.v311.netty.util.AbstractConstant
Creates a new instance.
accept(EndWithErrorExceptionVisitor) - Method in exception com.swiftmq.impl.amqp.amqp.v01_00_00.ConnectionEndException
 
accept(EndWithErrorExceptionVisitor) - Method in exception com.swiftmq.impl.amqp.amqp.v01_00_00.EndWithErrorException
 
accept(EndWithErrorExceptionVisitor) - Method in exception com.swiftmq.impl.amqp.amqp.v01_00_00.LinkEndException
 
accept(EndWithErrorExceptionVisitor) - Method in exception com.swiftmq.impl.amqp.amqp.v01_00_00.SessionEndException
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POActivateFlow
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POChannelFrameReceived
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POCheckIdleTimeout
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POClose
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POCloseChannel
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendChannelClose
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendClose
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendHeartBeat
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendMessages
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendStart
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendTune
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POCheckIdleTimeout
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POClose
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POCloseSession
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POConnectionCollect
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POConnectionFrameReceived
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSendBegin
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSendClose
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSendEnd
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSendFlow
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSendHeartBeat
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSendMessages
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSendOpen
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSessionCollect
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSessionFrameReceived
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.sasl.v01_00_00.po.POClose
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.sasl.v01_00_00.po.POSaslFrameReceived
 
accept(POVisitor) - Method in class com.swiftmq.impl.amqp.sasl.v01_00_00.po.POSendInit
 
accept(POVisitor) - Method in class com.swiftmq.impl.mgmt.standard.po.CheckExpire
 
accept(POVisitor) - Method in class com.swiftmq.impl.mgmt.standard.po.ClientRequest
 
accept(POVisitor) - Method in class com.swiftmq.impl.mgmt.standard.po.Close
 
accept(POVisitor) - Method in class com.swiftmq.impl.mgmt.standard.po.Disconnect
 
accept(POVisitor) - Method in class com.swiftmq.impl.mgmt.standard.po.EntityAdded
 
accept(POVisitor) - Method in class com.swiftmq.impl.mgmt.standard.po.EntityRemoved
 
accept(POVisitor) - Method in class com.swiftmq.impl.mgmt.standard.po.PropertyChanged
 
accept(POVisitor) - Method in class com.swiftmq.impl.mgmt.standard.po.RouterAvailable
 
accept(POVisitor) - Method in class com.swiftmq.impl.mgmt.standard.po.RouterUnavailable
 
accept(POVisitor) - Method in class com.swiftmq.impl.mgmt.standard.po.SendUpdates
 
accept(POVisitor) - Method in class com.swiftmq.impl.mgmt.standard.po.SwiftletAdded
 
accept(POVisitor) - Method in class com.swiftmq.impl.mgmt.standard.po.SwiftletRemoved
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POClose
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POCollect
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POConnect
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.PODisconnect
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POPingReq
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POProtocolError
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POPubAck
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POPubComp
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POPublish
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POPubRec
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POPubRel
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POSendMessage
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POSessionAssociated
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POSubscribe
 
accept(POVisitor) - Method in class com.swiftmq.impl.mqtt.po.POUnsubscribe
 
accept(POVisitor) - Method in class com.swiftmq.impl.routing.single.manager.po.POAddObject
 
accept(POVisitor) - Method in class com.swiftmq.impl.routing.single.manager.po.PORemoveAllObject
 
accept(POVisitor) - Method in class com.swiftmq.impl.routing.single.manager.po.PORemoveObject
 
accept(POVisitor) - Method in class com.swiftmq.impl.routing.single.route.po.POConnectionActivatedObject
 
accept(POVisitor) - Method in class com.swiftmq.impl.routing.single.route.po.POConnectionRemoveObject
 
accept(POVisitor) - Method in class com.swiftmq.impl.routing.single.route.po.PORouteObject
 
accept(POVisitor) - Method in class com.swiftmq.impl.routing.single.schedule.po.POCloseObject
 
accept(POVisitor) - Method in class com.swiftmq.impl.routing.single.schedule.po.POConnectionAddedObject
 
accept(POVisitor) - Method in class com.swiftmq.impl.routing.single.schedule.po.POConnectionRemovedObject
 
accept(POVisitor) - Method in class com.swiftmq.impl.routing.single.schedule.po.PODeliveredObject
 
accept(POVisitor) - Method in class com.swiftmq.impl.routing.single.schedule.po.PODeliverObject
 
accept(POVisitor) - Method in class com.swiftmq.impl.scheduler.standard.po.CalendarAdded
 
accept(POVisitor) - Method in class com.swiftmq.impl.scheduler.standard.po.CalendarChanged
 
accept(POVisitor) - Method in class com.swiftmq.impl.scheduler.standard.po.CalendarRemoved
 
accept(POVisitor) - Method in class com.swiftmq.impl.scheduler.standard.po.Close
 
accept(POVisitor) - Method in class com.swiftmq.impl.scheduler.standard.po.JobFactoryAdded
 
accept(POVisitor) - Method in class com.swiftmq.impl.scheduler.standard.po.JobFactoryRemoved
 
accept(POVisitor) - Method in class com.swiftmq.impl.scheduler.standard.po.JobStart
 
accept(POVisitor) - Method in class com.swiftmq.impl.scheduler.standard.po.JobStop
 
accept(POVisitor) - Method in class com.swiftmq.impl.scheduler.standard.po.JobTerminated
 
accept(POVisitor) - Method in class com.swiftmq.impl.scheduler.standard.po.ScheduleAdded
 
accept(POVisitor) - Method in class com.swiftmq.impl.scheduler.standard.po.ScheduleChanged
 
accept(POVisitor) - Method in class com.swiftmq.impl.scheduler.standard.po.ScheduleRemoved
 
accept(POVisitor) - Method in class com.swiftmq.impl.store.standard.processor.backup.po.BackupCompleted
 
accept(POVisitor) - Method in class com.swiftmq.impl.store.standard.processor.backup.po.ChangeGenerations
 
accept(POVisitor) - Method in class com.swiftmq.impl.store.standard.processor.backup.po.ChangePath
 
accept(POVisitor) - Method in class com.swiftmq.impl.store.standard.processor.backup.po.Close
 
accept(POVisitor) - Method in class com.swiftmq.impl.store.standard.processor.backup.po.ScanSaveSets
 
accept(POVisitor) - Method in class com.swiftmq.impl.store.standard.processor.backup.po.StartBackup
 
accept(POVisitor) - Method in class com.swiftmq.impl.store.standard.processor.scan.po.Close
 
accept(POVisitor) - Method in class com.swiftmq.impl.store.standard.processor.scan.po.StartScan
 
accept(POVisitor) - Method in class com.swiftmq.impl.store.standard.processor.shrink.po.Close
 
accept(POVisitor) - Method in class com.swiftmq.impl.store.standard.processor.shrink.po.StartShrink
 
accept(POVisitor) - Method in class com.swiftmq.impl.streams.processor.po.POClose
 
accept(POVisitor) - Method in class com.swiftmq.impl.streams.processor.po.POCollect
 
accept(POVisitor) - Method in class com.swiftmq.impl.streams.processor.po.POExecute
 
accept(POVisitor) - Method in class com.swiftmq.impl.streams.processor.po.POFunctionCallback
 
accept(POVisitor) - Method in class com.swiftmq.impl.streams.processor.po.POMessage
 
accept(POVisitor) - Method in class com.swiftmq.impl.streams.processor.po.POMgmtMessage
 
accept(POVisitor) - Method in class com.swiftmq.impl.streams.processor.po.POStart
 
accept(POVisitor) - Method in class com.swiftmq.impl.streams.processor.po.POTimer
 
accept(POVisitor) - Method in class com.swiftmq.impl.streams.processor.po.POWireTapMessage
 
accept(POVisitor) - Method in class com.swiftmq.impl.topic.standard.announce.po.POAnnounceSubscriptions
 
accept(POVisitor) - Method in class com.swiftmq.impl.topic.standard.announce.po.PODestinationActivated
 
accept(POVisitor) - Method in class com.swiftmq.impl.topic.standard.announce.po.PODestinationAdded
 
accept(POVisitor) - Method in class com.swiftmq.impl.topic.standard.announce.po.PODestinationDeactivated
 
accept(POVisitor) - Method in class com.swiftmq.impl.topic.standard.announce.po.PODestinationRemoved
 
accept(POVisitor) - Method in class com.swiftmq.impl.topic.standard.announce.po.POSubscriptionAdded
 
accept(POVisitor) - Method in class com.swiftmq.impl.topic.standard.announce.po.POSubscriptionRemoved
 
accept(POVisitor) - Method in class com.swiftmq.impl.topic.standard.announce.po.POTopicCreated
 
accept(POVisitor) - Method in class com.swiftmq.impl.topic.standard.announce.po.POTopicRemoved
 
accept(POVisitor) - Method in class com.swiftmq.impl.topic.standard.announce.po.POVersionNoteReceived
 
accept(POVisitor) - Method in class com.swiftmq.impl.topic.standard.announce.po.POVersionNoteToSend
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.jms.standard.v750.CollectRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.jms.standard.v750.DeliveryItem
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.jms.standard.v750.RegisterMessageProcessor
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.jms.standard.v750.RunMessageProcessor
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.BulkRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.CloseStageQueueRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.DeliveryRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.KeepAliveRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.ProtocolReplyRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.ProtocolRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.SendRouteRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.StartStageRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.AdjustRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.AuthReplyRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.AuthRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.CommitReplyRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.CommitRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ConnectReplyRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ConnectRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RecoveryReplyRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RecoveryRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RollbackReplyRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RollbackRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RouteRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.StartDeliveryRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ThrottleRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.TransactionRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.AdjustRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.AuthReplyRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.AuthRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.CommitReplyRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.CommitRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectReplyRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.NonXACommitRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.NonXATransactionRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RecoveryReplyRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RecoveryRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RollbackReplyRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RollbackRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RouteRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.StartDeliveryRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ThrottleRequest
 
accept(RequestVisitor) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.TransactionRequest
 
ack(MessageIndex) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.Consumer
 
ackMode - Variable in class com.swiftmq.impl.jms.standard.v750.SessionContext
 
acknowledgeMessage(Object, MessageIndex) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
acknowledgeMessage(Object, MessageIndex, AsyncCompletionCallback) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
acknowledgeMessages(Object, List, AsyncCompletionCallback) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
activate(boolean) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
Activate - Class in com.swiftmq.impl.queue.standard.command
 
Activate(SwiftletContext) - Constructor for class com.swiftmq.impl.queue.standard.command.Activate
 
activated(RoutingConnection) - Method in interface com.swiftmq.impl.routing.single.connection.event.ActivationListener
 
activated(RoutingConnection) - Method in class com.swiftmq.impl.routing.single.route.RouteExchanger
 
ActivationListener - Interface in com.swiftmq.impl.routing.single.connection.event
 
active(boolean) - Method in class com.swiftmq.impl.queue.standard.queue.FlowControllerImpl
 
activeDurableList - Variable in class com.swiftmq.impl.topic.standard.TopicManagerContext
 
activeLogin - Variable in class com.swiftmq.impl.jms.standard.v750.JMSConnection
 
activeLogin - Variable in class com.swiftmq.impl.jms.standard.v750.SessionContext
 
activeMessageScheduleList - Variable in class com.swiftmq.impl.scheduler.standard.SwiftletContext
 
ActiveQueueImpl - Class in com.swiftmq.impl.queue.standard.queue
 
ActiveQueueImpl(AbstractQueue, Entity) - Constructor for class com.swiftmq.impl.queue.standard.queue.ActiveQueueImpl
 
activeScheduleList - Variable in class com.swiftmq.impl.scheduler.standard.SwiftletContext
 
activeSubscriberList - Variable in class com.swiftmq.impl.topic.standard.TopicManagerContext
 
ActiveTransactionRegistry - Class in com.swiftmq.impl.queue.standard.queue
 
ActiveTransactionRegistry() - Constructor for class com.swiftmq.impl.queue.standard.queue.ActiveTransactionRegistry
 
add(IndexEntry) - Method in class com.swiftmq.impl.store.standard.index.Index
 
add(IndexEntry) - Method in class com.swiftmq.impl.store.standard.index.RootIndex
 
add(PrepareLogRecordImpl) - Method in class com.swiftmq.impl.store.standard.xa.PreparedLog
 
add(PrepareLogRecordImpl) - Method in class com.swiftmq.impl.store.standard.xa.PreparedLogFile
 
add(PrepareLogRecordImpl) - Method in class com.swiftmq.impl.store.standard.xa.PreparedLogQueue
 
add(Message) - Method in class com.swiftmq.impl.streams.comp.memory.HeapMemory
 
add(Message) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Add a Message to the Memory.
add(Message) - Method in class com.swiftmq.impl.streams.comp.memory.MemoryGroup
Adds a Message to this MemoryGroup.
add(Message) - Method in class com.swiftmq.impl.streams.comp.memory.QueueMemory
 
add(String, MQTTSession) - Method in class com.swiftmq.impl.mqtt.session.SessionStore
 
add(String, MqttPublishMessage) - Method in class com.swiftmq.impl.mqtt.retain.MemoryRetainer
 
add(String, MqttPublishMessage) - Method in interface com.swiftmq.impl.mqtt.retain.Retainer
 
add(String, DispatchPolicy) - Method in class com.swiftmq.impl.queue.standard.cluster.DispatchPolicyRegistry
 
add(StoreEntry) - Method in class com.swiftmq.impl.store.standard.index.QueueIndex
 
add(StoreEntry) - Method in interface com.swiftmq.impl.store.standard.swap.SwapFile
 
add(StoreEntry) - Method in class com.swiftmq.impl.store.standard.swap.SwapFileImpl
 
add(StoreEntry, boolean) - Method in class com.swiftmq.impl.store.standard.index.QueueIndex
 
ADD - Static variable in interface com.swiftmq.impl.routing.single.route.Route
 
addAnnualDay(String, int, int) - Method in class com.swiftmq.impl.scheduler.standard.SchedulerCalendar
 
addAnnualDay(String, int, String) - Method in class com.swiftmq.impl.scheduler.standard.SchedulerCalendar
 
addBodyPart(byte[]) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.MessageWrap
 
addByteCount(long) - Method in interface com.swiftmq.impl.net.netty.Countable
 
addByteCount(long) - Method in class com.swiftmq.impl.net.netty.CountableBufferedInputStream
 
addByteCount(long) - Method in class com.swiftmq.impl.net.netty.CountableBufferedOutputStream
 
addByteCount(long) - Method in class com.swiftmq.impl.net.netty.CountableInput
 
addByteCount(long) - Method in class com.swiftmq.impl.net.netty.CountableWrappedOutputStream
 
addClientId(String) - Method in class com.swiftmq.impl.jms.standard.JMSSwiftlet
 
addConnectId(String) - Method in class com.swiftmq.impl.amqp.SwiftletContext
 
addConnection(Connection) - Method in class com.swiftmq.impl.net.netty.ConnectionManagerImpl
 
addConnectionListener(ConnectionListener) - Method in class com.swiftmq.impl.routing.single.manager.ConnectionManager
 
addDateRange(String, String, String) - Method in class com.swiftmq.impl.scheduler.standard.SchedulerCalendar
 
addEntry(IndexEntry) - Method in class com.swiftmq.impl.store.standard.index.IndexPage
 
addEventLoop(EventLoopImpl) - Method in class com.swiftmq.impl.threadpool.standard.group.Group
 
addHeuristic(XidImpl, boolean) - Method in class com.swiftmq.impl.xa.standard.HeuristicHandler
 
addHop(String) - Method in interface com.swiftmq.impl.routing.single.route.Route
 
addHop(String) - Method in class com.swiftmq.impl.routing.single.route.v400.RouteImpl
 
addHost(String) - Method in class com.swiftmq.impl.auth.standard.User
 
addInput(String, Input) - Method in class com.swiftmq.impl.streams.Stream
Internal use only
addInstantTimerListener(long, TimerListener) - Method in class com.swiftmq.impl.timer.standard.TimerSwiftletImpl
 
addInstantTimerListener(long, TimerListener, boolean) - Method in class com.swiftmq.impl.timer.standard.TimerSwiftletImpl
 
addJDBCLookup(String, JDBCLookup) - Method in class com.swiftmq.impl.streams.Stream
Internal use only
addJobFactory(String, JobFactory) - Method in class com.swiftmq.impl.scheduler.standard.JobGroupImpl
 
addLatency(long) - Method in class com.swiftmq.impl.queue.standard.queue.QueueLatency
 
addLimit(Limit) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Internal use.
addLocalMetric(QueueMetric) - Method in interface com.swiftmq.impl.queue.standard.cluster.DispatchPolicy
 
addLocalMetric(QueueMetric) - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
addLocalMetric(QueueMetric) - Method in class com.swiftmq.impl.queue.standard.cluster.RoundRobinDispatchPolicy
 
addMailServer(String, MailServer) - Method in class com.swiftmq.impl.streams.Stream
Internal use only
addMemory(String, Memory) - Method in class com.swiftmq.impl.streams.Stream
Internal use only
addMemoryGroup(String, MemoryGroup) - Method in class com.swiftmq.impl.streams.Stream
Internal use only
addMessagePageReference(MessagePageReference) - Method in class com.swiftmq.impl.store.standard.StoreTransactionImpl
 
addMetric(String, ClusteredQueueMetric) - Method in interface com.swiftmq.impl.queue.standard.cluster.DispatchPolicy
 
addMetric(String, ClusteredQueueMetric) - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
addMetric(String, ClusteredQueueMetric) - Method in class com.swiftmq.impl.queue.standard.cluster.RoundRobinDispatchPolicy
 
addOutput(String, Output) - Method in class com.swiftmq.impl.streams.Stream
Internal use only
addPreparedTransaction(XidImpl, String, QueueTransaction) - Method in class com.swiftmq.impl.xa.standard.XAResourceManagerSwiftletImpl
 
addPropertyWatchListener(Property, PropertyWatchListener) - Method in class com.swiftmq.impl.queue.standard.queue.PropertyWatchManager
 
addQueueManagerListener(String, QueueManagerListener) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
addQueueManagerListener(QueueManagerListener) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
addRoute(Route) - Method in class com.swiftmq.impl.routing.single.route.RouteTable
 
addRoute(Route) - Method in class com.swiftmq.impl.routing.single.schedule.DefaultScheduler
 
addRoute(Route) - Method in class com.swiftmq.impl.routing.single.schedule.DefaultScheduler.ConnectionEntry
 
addRoute(Route) - Method in class com.swiftmq.impl.routing.single.schedule.Scheduler
 
addRoute(RouteImpl) - Method in class com.swiftmq.impl.routing.single.RoutingSwiftletImpl
 
addRouterName(String) - Method in class com.swiftmq.impl.routing.single.route.RouteFilter
 
addStaticSubscription(String, boolean) - Method in class com.swiftmq.impl.topic.standard.TopicBroker
 
addStaticSubscription(String, String, boolean) - Method in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
addSubscription(MqttQoS, String) - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageBuilders.SubscribeBuilder
 
addSystemTimeChangeListener(SystemTimeChangeListener) - Method in class com.swiftmq.impl.timer.standard.TimerSwiftletImpl
 
addTemporarySchedule(String, String, String, String, String, String, String, String, boolean) - Method in class com.swiftmq.impl.scheduler.standard.SchedulerSwiftletImpl
 
addTempQueue(String) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandler
 
addTempQueue(String, TempQueue) - Method in class com.swiftmq.impl.streams.Stream
Internal use only
addTimer(String, Timer) - Method in class com.swiftmq.impl.streams.Stream
Internal use only
addTimerListener(long, TimerListener) - Method in class com.swiftmq.impl.timer.standard.TimerSwiftletImpl
 
addTimerListener(long, TimerListener, boolean) - Method in class com.swiftmq.impl.timer.standard.TimerSwiftletImpl
 
addToIndexes(String, Message) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
 
addTopic(String, String[]) - Method in class com.swiftmq.impl.topic.standard.TopicBroker
 
addTopicAuthenticationDelegate(AuthenticationDelegate) - Method in class com.swiftmq.impl.auth.standard.AuthenticationSwiftletImpl
 
addTopicFilter(String) - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageBuilders.UnsubscribeBuilder
 
addToTransaction(TxnIdIF, SourceLink, long, MessageIndex, long) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.transaction.TransactionRegistry
 
addToTransaction(TxnIdIF, DispositionFrame) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.transaction.TransactionRegistry
 
addToTransaction(TxnIdIF, String, MessageImpl, TargetLink) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.transaction.TransactionRegistry
 
addTransaction(int, String, QueueTransaction) - Method in class com.swiftmq.impl.xa.standard.XALiveContextImpl
 
addTransaction(int, String, QueueTransaction) - Method in class com.swiftmq.impl.xa.standard.XARecoveryContextImpl
 
addTransaction(QueueTransaction, TransactionFinishListener) - Method in class com.swiftmq.impl.streams.StreamContext
 
addTransactionFlushListener(TransactionFlushListener) - Method in class com.swiftmq.impl.streams.StreamContext
 
addTransferFrame(TransferFrame) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
addUnacked(long, Consumer, MessageIndex, int) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.ChannelHandler
 
addUnsettled(long, MessageIndex) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
addUnsettled(long, MessageIndex, long) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
addWireTapSubscriber(String, WireTapSubscriber) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
addWireTapSubscriber(String, WireTapSubscriber) - Method in class com.swiftmq.impl.queue.standard.queue.WireTapManager
 
ADJUST_REQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v400.SMQRFactory
 
ADJUST_REQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v942.SMQRFactory
 
AdjustRequest - Class in com.swiftmq.impl.routing.single.smqpr.v400
 
AdjustRequest - Class in com.swiftmq.impl.routing.single.smqpr.v942
 
AdjustRequest(int, int) - Constructor for class com.swiftmq.impl.routing.single.smqpr.v400.AdjustRequest
 
AdjustRequest(int, int) - Constructor for class com.swiftmq.impl.routing.single.smqpr.v942.AdjustRequest
 
adminRole(String) - Method in class com.swiftmq.impl.streams.comp.management.CLI
Sets the name of the admin role to use.
adminToolActivated() - Method in class com.swiftmq.impl.amqp.AMQPSwiftlet
 
adminToolActivated() - Method in class com.swiftmq.impl.jms.standard.JMSSwiftlet
 
adminToolActivated() - Method in class com.swiftmq.impl.mqtt.MQTTSwiftlet
 
adminToolActivated() - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
adminToolDeactivated() - Method in class com.swiftmq.impl.amqp.AMQPSwiftlet
 
adminToolDeactivated() - Method in class com.swiftmq.impl.jms.standard.JMSSwiftlet
 
adminToolDeactivated() - Method in class com.swiftmq.impl.mqtt.MQTTSwiftlet
 
adminToolDeactivated() - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
advanceDeliveryCount() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
AMQP_INIT - Static variable in class com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandlerFactory
 
AMQP_INIT - Static variable in class com.swiftmq.impl.amqp.amqp.v01_00_00.AMQPHandlerFactory
 
AMQPChannelVisitor - Interface in com.swiftmq.impl.amqp.amqp.v00_09_01
 
AMQPConnectionVisitor - Interface in com.swiftmq.impl.amqp.amqp.v00_09_01
 
AMQPConnectionVisitor - Interface in com.swiftmq.impl.amqp.amqp.v01_00_00
 
AMQPHandler - Class in com.swiftmq.impl.amqp.amqp.v00_09_01
 
AMQPHandler - Class in com.swiftmq.impl.amqp.amqp.v01_00_00
 
AMQPHandler(SwiftletContext, VersionedConnection) - Constructor for class com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandler
 
AMQPHandler(SwiftletContext, VersionedConnection) - Constructor for class com.swiftmq.impl.amqp.amqp.v01_00_00.AMQPHandler
 
AMQPHandlerFactory - Class in com.swiftmq.impl.amqp.amqp.v00_09_01
 
AMQPHandlerFactory - Class in com.swiftmq.impl.amqp.amqp.v01_00_00
 
AMQPHandlerFactory(SwiftletContext) - Constructor for class com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandlerFactory
 
AMQPHandlerFactory(SwiftletContext) - Constructor for class com.swiftmq.impl.amqp.amqp.v01_00_00.AMQPHandlerFactory
 
AMQPNativeInboundTransformer - Class in com.swiftmq.impl.amqp.amqp.v01_00_00.transformer
 
AMQPNativeInboundTransformer() - Constructor for class com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.AMQPNativeInboundTransformer
 
AMQPNativeOutboundTransformer - Class in com.swiftmq.impl.amqp.amqp.v01_00_00.transformer
 
AMQPNativeOutboundTransformer() - Constructor for class com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.AMQPNativeOutboundTransformer
 
AMQPSessionVisitor - Interface in com.swiftmq.impl.amqp.amqp.v01_00_00
 
amqpSwiftlet - Variable in class com.swiftmq.impl.amqp.SwiftletContext
 
AMQPSwiftlet - Class in com.swiftmq.impl.amqp
 
AMQPSwiftlet() - Constructor for class com.swiftmq.impl.amqp.AMQPSwiftlet
 
analyzeQueueIndex(PrintWriter, int) - Method in class com.swiftmq.impl.store.standard.index.IndexAnalyzer
 
analyzeRootIndex(PrintWriter) - Method in class com.swiftmq.impl.store.standard.index.IndexAnalyzer
 
announceFilterList - Variable in class com.swiftmq.impl.topic.standard.TopicManagerContext
 
AnnounceFilters - Class in com.swiftmq.impl.topic.standard.announce
 
AnnounceFilters(TopicManagerContext) - Constructor for class com.swiftmq.impl.topic.standard.announce.AnnounceFilters
 
announceReceiver - Variable in class com.swiftmq.impl.topic.standard.TopicManagerContext
 
announceSender - Variable in class com.swiftmq.impl.topic.standard.TopicManagerContext
 
announceSubscriptions(TopicInfo) - Method in class com.swiftmq.impl.topic.standard.announce.TopicAnnounceSender
 
AnonServer - Class in com.swiftmq.impl.amqp.sasl.provider
 
AnonServer(CallbackHandler) - Constructor for class com.swiftmq.impl.amqp.sasl.provider.AnonServer
 
AppendLogFile - Class in com.swiftmq.impl.store.standard.log
 
AppendLogFile(StoreContext, RandomAccessFile) - Constructor for class com.swiftmq.impl.store.standard.log.AppendLogFile
 
applyDispositionFrame(DispositionFrame) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler
 
ascendingSeries(String) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Returns true if all values of a Property are greater than the previous value.
associate(MQTTConnection) - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
associated(MQTTSession) - Method in class com.swiftmq.impl.mqtt.connection.MQTTConnection
 
associated(MQTTSession) - Method in interface com.swiftmq.impl.mqtt.session.AssociateSessionCallback
 
associateSession(String, AssociateSessionCallback) - Method in class com.swiftmq.impl.mqtt.session.SessionRegistry
 
AssociateSessionCallback - Interface in com.swiftmq.impl.mqtt.session
 
async(String, Object) - Method in class com.swiftmq.impl.streams.Stream
Wraps an async callback with a proxy that implements the interface given by the "interfaceClassName" and runs the callback on the Stream's event queue.
AsyncMessageProcessor - Class in com.swiftmq.impl.jms.standard.v750
 
AsyncMessageProcessor(Session, SessionContext, Consumer, int, int) - Constructor for class com.swiftmq.impl.jms.standard.v750.AsyncMessageProcessor
 
AsyncProxy - Class in com.swiftmq.impl.streams
Proxy to intercept asynchronous callbacks and executes them on the stream's event queue
at() - Method in class com.swiftmq.impl.streams.comp.timer.TimerBuilder
Creates an AtTimer.
at(int) - Method in class com.swiftmq.impl.streams.comp.memory.HeapMemory
 
at(int) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Returns the Message at the index.
at(int) - Method in class com.swiftmq.impl.streams.comp.memory.QueueMemory
 
AT - Static variable in class com.swiftmq.impl.scheduler.standard.ScheduleFactory
 
AT_LEAST_ONCE - Enum constant in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttQoS
 
AT_MOST_ONCE - Enum constant in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttQoS
 
AtSchedule - Class in com.swiftmq.impl.scheduler.standard
 
AtSchedule(String, boolean, boolean, String, String, String, String, String, long, String, int[]) - Constructor for class com.swiftmq.impl.scheduler.standard.AtSchedule
 
AtTimer - Class in com.swiftmq.impl.streams.comp.timer
At Timer implementation.
AUTH_REPREQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v400.SMQRFactory
 
AUTH_REPREQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v942.SMQRFactory
 
AUTH_REQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v400.SMQRFactory
 
AUTH_REQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v942.SMQRFactory
 
authEnabled - Variable in class com.swiftmq.impl.mgmt.standard.SwiftletContext
 
authenticationSwiftlet - Variable in class com.swiftmq.impl.streams.SwiftletContext
 
AuthenticationSwiftletImpl - Class in com.swiftmq.impl.auth.standard
 
AuthenticationSwiftletImpl() - Constructor for class com.swiftmq.impl.auth.standard.AuthenticationSwiftletImpl
 
AuthenticatorImpl - Class in com.swiftmq.impl.mgmt.standard.auth
 
AuthenticatorImpl(SwiftletContext, Role) - Constructor for class com.swiftmq.impl.mgmt.standard.auth.AuthenticatorImpl
 
AuthReplyRequest - Class in com.swiftmq.impl.routing.single.smqpr.v400
 
AuthReplyRequest - Class in com.swiftmq.impl.routing.single.smqpr.v942
 
AuthReplyRequest() - Constructor for class com.swiftmq.impl.routing.single.smqpr.v400.AuthReplyRequest
 
AuthReplyRequest() - Constructor for class com.swiftmq.impl.routing.single.smqpr.v942.AuthReplyRequest
 
AuthRequest - Class in com.swiftmq.impl.routing.single.smqpr.v400
 
AuthRequest - Class in com.swiftmq.impl.routing.single.smqpr.v942
 
AuthRequest(Serializable) - Constructor for class com.swiftmq.impl.routing.single.smqpr.v400.AuthRequest
 
AuthRequest(Serializable) - Constructor for class com.swiftmq.impl.routing.single.smqpr.v942.AuthRequest
 
AuthStage - Class in com.swiftmq.impl.routing.single.connection.v942
 
AuthStage(SwiftletContext, RoutingConnection, ConnectReplyRequest) - Constructor for class com.swiftmq.impl.routing.single.connection.v942.AuthStage
 
authSwiftlet - Variable in class com.swiftmq.impl.amqp.SwiftletContext
 
authSwiftlet - Variable in class com.swiftmq.impl.jms.standard.SwiftletContext
 
authSwiftlet - Variable in class com.swiftmq.impl.jms.standard.v750.SessionContext
 
authSwiftlet - Variable in class com.swiftmq.impl.mqtt.SwiftletContext
 
authSwiftlet - Variable in class com.swiftmq.impl.queue.standard.SwiftletContext
 
authSwiftlet - Variable in class com.swiftmq.impl.topic.standard.TopicManagerContext
 
autoack(MessageIndex) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
available() - Method in class com.swiftmq.impl.net.netty.CountableBufferedInputStream
 
available() - Method in class com.swiftmq.impl.store.standard.index.IndexPage
 
average(String) - Method in class com.swiftmq.impl.streams.comp.memory.GroupResult
Determines the average value of a Property and returns the result as a new non-queue Memory with Messages that contains 2 Properties, the grouping Property and the average Property.
average(String) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Returns the average of all values of a Property.

B

backup(String) - Method in class com.swiftmq.impl.store.standard.xa.PreparedLog
 
backup(String) - Method in class com.swiftmq.impl.store.standard.xa.PreparedLogFile
 
backup(String) - Method in class com.swiftmq.impl.store.standard.xa.PreparedLogQueue
 
BackupCompleted - Class in com.swiftmq.impl.store.standard.processor.backup.po
 
BackupCompleted() - Constructor for class com.swiftmq.impl.store.standard.processor.backup.po.BackupCompleted
 
backupEntity - Variable in class com.swiftmq.impl.store.standard.StoreContext
 
backupFinished(boolean, String) - Method in class com.swiftmq.impl.store.standard.jobs.BackupJob
 
backupFinished(boolean, String) - Method in interface com.swiftmq.impl.store.standard.processor.backup.BackupFinishedListener
 
BackupFinishedListener - Interface in com.swiftmq.impl.store.standard.processor.backup
 
BackupJob - Class in com.swiftmq.impl.store.standard.jobs
 
BackupJob(StoreContext) - Constructor for class com.swiftmq.impl.store.standard.jobs.BackupJob
 
BackupJobFactory - Class in com.swiftmq.impl.store.standard.jobs
 
BackupJobFactory(StoreContext) - Constructor for class com.swiftmq.impl.store.standard.jobs.BackupJobFactory
 
backupList - Variable in class com.swiftmq.impl.store.standard.StoreContext
 
backupProcessor - Variable in class com.swiftmq.impl.store.standard.StoreContext
 
BackupProcessor - Class in com.swiftmq.impl.store.standard.processor.backup
 
BackupProcessor(StoreContext) - Constructor for class com.swiftmq.impl.store.standard.processor.backup.BackupProcessor
 
backupRequired() - Method in class com.swiftmq.impl.store.standard.xa.PreparedLog
 
backupRequired() - Method in class com.swiftmq.impl.store.standard.xa.PreparedLogFile
 
backupRequired() - Method in class com.swiftmq.impl.store.standard.xa.PreparedLogQueue
 
BasicInboundTransformer - Class in com.swiftmq.impl.amqp.amqp.v00_09_01.transformer
 
BasicInboundTransformer() - Constructor for class com.swiftmq.impl.amqp.amqp.v00_09_01.transformer.BasicInboundTransformer
 
BasicOutboundTransformer - Class in com.swiftmq.impl.amqp.amqp.v00_09_01.transformer
 
BasicOutboundTransformer() - Constructor for class com.swiftmq.impl.amqp.amqp.v00_09_01.transformer.BasicOutboundTransformer
 
bcc(String) - Method in class com.swiftmq.impl.streams.comp.io.Email
Sets the bcc address
beforeTransactionComplete() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
beginOfDay() - Method in class com.swiftmq.impl.streams.comp.timer.NextTimer
Starts the timer at the begin of the next day
beginOfHour() - Method in class com.swiftmq.impl.streams.comp.timer.NextTimer
Starts the timer at the begin of the next hour
beginOfMinute() - Method in class com.swiftmq.impl.streams.comp.timer.NextTimer
Starts the timer at the begin of the next minute
beginOfSecond() - Method in class com.swiftmq.impl.streams.comp.timer.NextTimer
Starts the timer at the begin of the next second
bind(String, Object) - Method in class com.swiftmq.impl.jndi.standard.JNDIReplication
 
bindings - Variable in class com.swiftmq.impl.streams.StreamContext
 
body() - Method in class com.swiftmq.impl.streams.comp.message.BytesMessage
Returns the body.
body() - Method in class com.swiftmq.impl.streams.comp.message.MapMessage
Returns the body.
body() - Method in class com.swiftmq.impl.streams.comp.message.ObjectMessage
Returns the body.
body() - Method in class com.swiftmq.impl.streams.comp.message.StreamMessage
Returns the body.
body() - Method in class com.swiftmq.impl.streams.comp.message.TextMessage
Returns the body.
body(byte[]) - Method in class com.swiftmq.impl.streams.comp.message.BytesMessage
Sets the body.
body(Serializable) - Method in class com.swiftmq.impl.streams.comp.message.ObjectMessage
Sets the body.
body(String) - Method in class com.swiftmq.impl.streams.comp.io.Email
Sets the mail body.
body(String) - Method in class com.swiftmq.impl.streams.comp.message.TextMessage
Sets the body.
BodyFactory - Interface in com.swiftmq.impl.amqp.amqp.v01_00_00.transformer
 
BodyTypeMessageFactory - Class in com.swiftmq.impl.amqp.amqp.v01_00_00.transformer
 
BodyTypeMessageFactory() - Constructor for class com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.BodyTypeMessageFactory
 
BrowserManager - Class in com.swiftmq.impl.jms.standard.v750
 
BrowserManager(SessionContext) - Constructor for class com.swiftmq.impl.jms.standard.v750.BrowserManager
 
bufferSize(int) - Method in class com.swiftmq.impl.streams.comp.io.QueueWireTapInput
Sets the bufferSize of the internal BlockingQueue.
build() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageBuilders.ConnAckBuilder
 
build() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageBuilders.ConnectBuilder
 
build() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageBuilders.PublishBuilder
 
build() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageBuilders.SubscribeBuilder
 
build() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageBuilders.UnsubscribeBuilder
 
buildDuplicateBacklog() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
buildPreparedTransaction(PrepareLogRecord) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
buildQueueIndexReferences(int) - Method in class com.swiftmq.impl.store.standard.index.IndexAnalyzer
 
buildReferences() - Method in class com.swiftmq.impl.store.standard.index.IndexAnalyzer
 
BULK_REQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.SMQRFactory
 
BulkRequest - Class in com.swiftmq.impl.routing.single.smqpr
 
BulkRequest() - Constructor for class com.swiftmq.impl.routing.single.smqpr.BulkRequest
 
BulkRequest(DumpableFactory) - Constructor for class com.swiftmq.impl.routing.single.smqpr.BulkRequest
 
ByteBuf - Class in com.swiftmq.impl.mqtt.v311.netty.buffer
 
ByteBuf(byte[]) - Constructor for class com.swiftmq.impl.mqtt.v311.netty.buffer.ByteBuf
 
ByteBuf(byte[], int, int) - Constructor for class com.swiftmq.impl.mqtt.v311.netty.buffer.ByteBuf
 
ByteBuf(int) - Constructor for class com.swiftmq.impl.mqtt.v311.netty.buffer.ByteBuf
 
bytesMessage() - Method in class com.swiftmq.impl.streams.comp.message.MessageBuilder
Returns a new BytesMessage facade.
BytesMessage - Class in com.swiftmq.impl.streams.comp.message
Facade to wrap a javax.jms.BytesMessage.
byteValue() - Method in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnectReturnCode
 

C

Cache - Interface in com.swiftmq.impl.queue.standard.queue
 
cacheEntity - Variable in class com.swiftmq.impl.store.standard.StoreContext
 
CacheImpl - Class in com.swiftmq.impl.queue.standard.queue
 
CacheImpl(int, int, PersistentStore, NonPersistentStore) - Constructor for class com.swiftmq.impl.queue.standard.queue.CacheImpl
 
cacheManager - Variable in class com.swiftmq.impl.store.standard.StoreContext
 
CacheManager - Class in com.swiftmq.impl.store.standard.cache
 
CacheManager(StoreContext, StableStore, int, int) - Constructor for class com.swiftmq.impl.store.standard.cache.CacheManager
 
CacheReleaseListener - Interface in com.swiftmq.impl.store.standard.cache
 
cacheTableFactory - Variable in class com.swiftmq.impl.queue.standard.SwiftletContext
 
CacheTableFactory - Interface in com.swiftmq.impl.queue.standard.queue
 
CacheTableFactoryImpl - Class in com.swiftmq.impl.queue.standard.queue
 
CacheTableFactoryImpl() - Constructor for class com.swiftmq.impl.queue.standard.queue.CacheTableFactoryImpl
 
CalendarAdded - Class in com.swiftmq.impl.scheduler.standard.po
 
CalendarAdded(SchedulerCalendar) - Constructor for class com.swiftmq.impl.scheduler.standard.po.CalendarAdded
 
CalendarChanged - Class in com.swiftmq.impl.scheduler.standard.po
 
CalendarChanged(SchedulerCalendar) - Constructor for class com.swiftmq.impl.scheduler.standard.po.CalendarChanged
 
CalendarFactory - Class in com.swiftmq.impl.scheduler.standard
 
CalendarFactory() - Constructor for class com.swiftmq.impl.scheduler.standard.CalendarFactory
 
CalendarRemoved - Class in com.swiftmq.impl.scheduler.standard.po
 
CalendarRemoved(String) - Constructor for class com.swiftmq.impl.scheduler.standard.po.CalendarRemoved
 
callback - Variable in class com.swiftmq.impl.routing.single.smqpr.DeliveryRequest
 
cause() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.DecoderResult
 
cc(String) - Method in class com.swiftmq.impl.streams.comp.io.Email
Sets the jms.cc address
challengeResponseFactory - Variable in class com.swiftmq.impl.mgmt.standard.SwiftletContext
 
challengeResponseFactory - Variable in class com.swiftmq.impl.routing.single.SwiftletContext
 
ChangeGenerations - Class in com.swiftmq.impl.store.standard.processor.backup.po
 
ChangeGenerations(Semaphore, int) - Constructor for class com.swiftmq.impl.store.standard.processor.backup.po.ChangeGenerations
 
ChangePath - Class in com.swiftmq.impl.store.standard.processor.backup.po
 
ChangePath(Semaphore, String) - Constructor for class com.swiftmq.impl.store.standard.processor.backup.po.ChangePath
 
channelActive(ChannelHandlerContext) - Method in class com.swiftmq.impl.net.netty.scheduler.NettyOutboundConnectionHandler
 
ChannelHandler - Class in com.swiftmq.impl.amqp.amqp.v00_09_01
 
ChannelHandler(SwiftletContext, AMQPHandler, int) - Constructor for class com.swiftmq.impl.amqp.amqp.v00_09_01.ChannelHandler
 
channelInactive(ChannelHandlerContext) - Method in class com.swiftmq.impl.net.netty.scheduler.NettyInboundConnectionHandler
 
channelInactive(ChannelHandlerContext) - Method in class com.swiftmq.impl.net.netty.scheduler.NettyOutboundConnectionHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class com.swiftmq.impl.net.netty.scheduler.NettyInboundConnectionHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class com.swiftmq.impl.net.netty.scheduler.NettyOutboundConnectionHandler
 
checkClosedAsync(AsyncCompletionCallback) - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
checkClosedAsync(AsyncCompletionCallback) - Method in class com.swiftmq.impl.store.standard.StoreTransactionImpl
 
checkConsistency(boolean) - Method in class com.swiftmq.impl.store.standard.index.IndexAnalyzer
 
CheckExpire - Class in com.swiftmq.impl.mgmt.standard.po
 
CheckExpire() - Constructor for class com.swiftmq.impl.mgmt.standard.po.CheckExpire
 
checkLimit() - Method in class com.swiftmq.impl.streams.comp.memory.limit.CountLimit
 
checkLimit() - Method in interface com.swiftmq.impl.streams.comp.memory.limit.Limit
Checks the Memory limits and deletes Messages that doesn't fit in the limit
checkLimit() - Method in class com.swiftmq.impl.streams.comp.memory.limit.TimeLimit
 
checkLimit() - Method in class com.swiftmq.impl.streams.comp.memory.limit.TimeUnitChangeLimit
 
checkLimit() - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Checks the limit of the Memory and retires Messages, if necessary.
checkLimit() - Method in class com.swiftmq.impl.streams.comp.memory.MemoryGroup
Checks inactivity and calls checkLimit() on each Memory of this MemoryGroup
checkNonEmpty(T[], String) - Static method in class com.swiftmq.impl.mqtt.v311.netty.util.internal.ObjectUtil
Checks that the given argument is neither null nor empty.
checkNonEmpty(T, String) - Static method in class com.swiftmq.impl.mqtt.v311.netty.util.internal.ObjectUtil
Checks that the given argument is neither null nor empty.
checkNotNull(T, String) - Static method in class com.swiftmq.impl.mqtt.v311.netty.util.internal.ObjectUtil
Checks that the given argument is not null.
checkPointDone() - Method in interface com.swiftmq.impl.store.standard.log.CheckPointHandler
 
checkPointDone() - Method in class com.swiftmq.impl.store.standard.transaction.TransactionManager
 
checkpointFinished() - Method in interface com.swiftmq.impl.store.standard.log.CheckPointFinishedListener
 
checkpointFinished() - Method in class com.swiftmq.impl.store.standard.processor.backup.BackupProcessor
 
checkpointFinished() - Method in class com.swiftmq.impl.store.standard.processor.scan.ScanProcessor
 
checkpointFinished() - Method in class com.swiftmq.impl.store.standard.processor.shrink.ShrinkProcessor
 
CheckPointFinishedListener - Interface in com.swiftmq.impl.store.standard.log
 
CheckPointHandler - Interface in com.swiftmq.impl.store.standard.log
 
checkPointVerbose - Static variable in interface com.swiftmq.impl.store.standard.log.LogManager
 
checkPositive(int, String) - Static method in class com.swiftmq.impl.mqtt.v311.netty.util.internal.ObjectUtil
Checks that the given argument is strictly positive.
checkPositive(long, String) - Static method in class com.swiftmq.impl.mqtt.v311.netty.util.internal.ObjectUtil
Checks that the given argument is strictly positive.
checkPositiveOrZero(int, String) - Static method in class com.swiftmq.impl.mqtt.v311.netty.util.internal.ObjectUtil
Checks that the given argument is positive or zero.
checkPositiveOrZero(long, String) - Static method in class com.swiftmq.impl.mqtt.v311.netty.util.internal.ObjectUtil
Checks that the given argument is positive or zero.
chunkCompleted(byte[], int, int) - Method in class com.swiftmq.impl.net.netty.scheduler.IntraVMServerEndpointImpl
 
chunkCompleted(byte[], int, int) - Method in class com.swiftmq.impl.net.netty.scheduler.NettyInboundConnectionHandler
 
chunkCompleted(byte[], int, int) - Method in class com.swiftmq.impl.net.netty.scheduler.NettyOutboundConnectionHandler
 
classLoader - Variable in class com.swiftmq.impl.streams.StreamContext
 
cleanSession(boolean) - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageBuilders.ConnectBuilder
 
cleanUpExpiredMessages() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
clear() - Method in interface com.swiftmq.impl.queue.standard.queue.Cache
 
clear() - Method in class com.swiftmq.impl.queue.standard.queue.CacheImpl
 
clear() - Method in class com.swiftmq.impl.store.standard.index.ReferenceMap
 
clear() - Method in class com.swiftmq.impl.streams.comp.memory.HeapMemory
 
clear() - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Removes all Messages from this Memory.
clear() - Method in class com.swiftmq.impl.streams.comp.memory.QueueMemory
 
clear() - Method in class com.swiftmq.impl.streams.comp.message.MapBody
Clears the body.
clear() - Method in class com.swiftmq.impl.streams.comp.message.Property
Clears the property value.
clearBody() - Method in class com.swiftmq.impl.streams.comp.message.Message
Clears the message body.
clearIndexes() - Method in class com.swiftmq.impl.streams.comp.memory.Memory
 
clearLastCollectTime() - Method in class com.swiftmq.impl.net.netty.ConnectionManagerImpl
 
clearMessageProcessor() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
cli() - Method in class com.swiftmq.impl.streams.Stream
Returns the stream's CLI
CLI - Class in com.swiftmq.impl.streams.comp.management
Executor class for CLI commands.
CLI(StreamContext) - Constructor for class com.swiftmq.impl.streams.comp.management.CLI
Internal use.
clientClose() - Method in class com.swiftmq.impl.net.netty.scheduler.IntraVMServerEndpointImpl
 
clientDispatchId - Variable in class com.swiftmq.impl.jms.standard.v750.Consumer
 
clientId(String) - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageBuilders.ConnectBuilder
 
clientId(String) - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
Sets the client id for a durable subscriber.
clientIdentifier() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnectPayload
 
clientListenerId - Variable in class com.swiftmq.impl.jms.standard.v750.Consumer
 
ClientRequest - Class in com.swiftmq.impl.mgmt.standard.po
 
ClientRequest(String, String, byte[]) - Constructor for class com.swiftmq.impl.mgmt.standard.po.ClientRequest
 
CLIExecutorImpl - Class in com.swiftmq.impl.mgmt.standard
 
close() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandler
 
close() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.ChannelHandler
 
close() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.Consumer
 
close() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.AMQPHandler
 
close() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
close() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler
 
close() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
close() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
close() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.transaction.TransactionRegistry
 
close() - Method in interface com.swiftmq.impl.amqp.Handler
 
close() - Method in class com.swiftmq.impl.amqp.OutboundQueue
 
close() - Method in class com.swiftmq.impl.amqp.sasl.v01_00_00.SASLHandler
 
close() - Method in class com.swiftmq.impl.amqp.VersionedConnection
 
close() - Method in class com.swiftmq.impl.deploy.standard.DeploySpaceImpl
 
close() - Method in class com.swiftmq.impl.jms.standard.v750.BrowserManager
 
close() - Method in class com.swiftmq.impl.jms.standard.v750.Consumer
 
close() - Method in class com.swiftmq.impl.jms.standard.v750.JMSConnection
 
close() - Method in class com.swiftmq.impl.jms.standard.v750.NontransactedQueueSession
 
close() - Method in class com.swiftmq.impl.jms.standard.v750.NontransactedSession
 
close() - Method in class com.swiftmq.impl.jms.standard.v750.NontransactedUnifiedSession
 
close() - Method in class com.swiftmq.impl.jms.standard.v750.OutboundWriter
 
close() - Method in class com.swiftmq.impl.jms.standard.v750.Producer
 
close() - Method in class com.swiftmq.impl.jms.standard.v750.Session
 
close() - Method in class com.swiftmq.impl.jms.standard.v750.TopicConsumer
 
close() - Method in class com.swiftmq.impl.jms.standard.v750.TransactedQueueSession
 
close() - Method in class com.swiftmq.impl.jms.standard.v750.TransactedTopicSession
 
close() - Method in class com.swiftmq.impl.jms.standard.v750.TransactedUnifiedSession
 
close() - Method in interface com.swiftmq.impl.jms.standard.VersionedJMSConnection
 
close() - Method in class com.swiftmq.impl.jms.standard.VersionSelector
 
close() - Method in class com.swiftmq.impl.jndi.standard.JNDIReplication
 
close() - Method in class com.swiftmq.impl.jndi.standard.QueueJNDIProcessor
 
close() - Method in class com.swiftmq.impl.jndi.standard.TopicJNDIProcessor
 
close() - Method in class com.swiftmq.impl.log.standard.LogSinkImpl
 
close() - Method in interface com.swiftmq.impl.mgmt.standard.Dispatcher
 
close() - Method in class com.swiftmq.impl.mgmt.standard.DispatchQueue
 
close() - Method in class com.swiftmq.impl.mgmt.standard.jmx.EntityMBean
 
close() - Method in class com.swiftmq.impl.mgmt.standard.Listener
 
close() - Method in class com.swiftmq.impl.mgmt.standard.MessageInterfaceController
 
close() - Method in class com.swiftmq.impl.mgmt.standard.MessageInterfaceListener
 
close() - Method in class com.swiftmq.impl.mgmt.standard.SwiftletContext
 
close() - Method in class com.swiftmq.impl.mgmt.standard.v750.DispatcherImpl
 
close() - Method in class com.swiftmq.impl.mqtt.connection.MQTTConnection
 
close() - Method in class com.swiftmq.impl.mqtt.pubsub.Consumer
 
close() - Method in class com.swiftmq.impl.mqtt.pubsub.DurableConsumer
 
close() - Method in class com.swiftmq.impl.mqtt.pubsub.Subscription
 
close() - Method in class com.swiftmq.impl.mqtt.retain.MemoryRetainer
 
close() - Method in interface com.swiftmq.impl.mqtt.retain.Retainer
 
close() - Method in class com.swiftmq.impl.mqtt.session.SessionRegistry
 
close() - Method in class com.swiftmq.impl.net.netty.scheduler.IntraVMScheduler
 
close() - Method in class com.swiftmq.impl.net.netty.scheduler.IntraVMServerEndpointImpl
 
close() - Method in class com.swiftmq.impl.net.netty.scheduler.IOScheduler
 
close() - Method in class com.swiftmq.impl.net.netty.scheduler.NettyConnection
 
close() - Method in class com.swiftmq.impl.net.netty.scheduler.NettyTCPConnector
 
close() - Method in class com.swiftmq.impl.net.netty.scheduler.NettyTCPListener
 
close() - Method in class com.swiftmq.impl.net.netty.scheduler.TCPConnector
 
close() - Method in class com.swiftmq.impl.net.netty.scheduler.TCPListener
 
close() - Method in class com.swiftmq.impl.queue.standard.cluster.ClusterMetricPublisher
 
close() - Method in class com.swiftmq.impl.queue.standard.cluster.ClusterMetricSubscriber
 
close() - Method in interface com.swiftmq.impl.queue.standard.cluster.DispatchPolicy
 
close() - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
close() - Method in class com.swiftmq.impl.queue.standard.cluster.RedispatcherController
 
close() - Method in class com.swiftmq.impl.queue.standard.cluster.RoundRobinDispatchPolicy
 
close() - Method in class com.swiftmq.impl.queue.standard.command.ViewCollector
 
close() - Method in class com.swiftmq.impl.queue.standard.queue.View
 
close() - Method in class com.swiftmq.impl.routing.single.connection.OutboundWriter
 
close() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
close() - Method in class com.swiftmq.impl.routing.single.connection.stage.ProtocolSelectStage
 
close() - Method in class com.swiftmq.impl.routing.single.connection.stage.Stage
 
close() - Method in class com.swiftmq.impl.routing.single.connection.stage.StageQueue
 
close() - Method in class com.swiftmq.impl.routing.single.connection.v942.AuthStage
 
close() - Method in class com.swiftmq.impl.routing.single.connection.v942.ConnectStage
 
close() - Method in class com.swiftmq.impl.routing.single.connection.v942.NonXADeliveryStage
 
close() - Method in class com.swiftmq.impl.routing.single.connection.v942.ThrottleQueue
 
close() - Method in class com.swiftmq.impl.routing.single.connection.v942.XADeliveryStage
 
close() - Method in class com.swiftmq.impl.routing.single.connection.v942.XARecoveryStage
 
close() - Method in class com.swiftmq.impl.routing.single.manager.ConnectionManager
 
close() - Method in class com.swiftmq.impl.routing.single.route.RouteExchanger
 
close() - Method in class com.swiftmq.impl.routing.single.schedule.DefaultScheduler
 
close() - Method in class com.swiftmq.impl.routing.single.schedule.Scheduler
 
close() - Method in class com.swiftmq.impl.routing.single.schedule.SchedulerRegistry
 
close() - Method in class com.swiftmq.impl.scheduler.standard.Scheduler
 
close() - Method in class com.swiftmq.impl.scheduler.standard.SwiftletContext
 
close() - Method in class com.swiftmq.impl.store.standard.cache.CacheManager
 
close() - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
close() - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
close() - Method in class com.swiftmq.impl.store.standard.DurableSubscriberStoreImpl
 
close() - Method in class com.swiftmq.impl.store.standard.NonPersistentStoreImpl
 
close() - Method in class com.swiftmq.impl.store.standard.PersistentStoreImpl
 
close() - Method in class com.swiftmq.impl.store.standard.processor.backup.BackupProcessor
 
close() - Method in class com.swiftmq.impl.store.standard.processor.scan.ScanProcessor
 
close() - Method in class com.swiftmq.impl.store.standard.processor.shrink.ShrinkProcessor
 
close() - Method in class com.swiftmq.impl.store.standard.StoreReadTransactionImpl
 
close() - Method in class com.swiftmq.impl.store.standard.StoreTransactionImpl
 
close() - Method in class com.swiftmq.impl.store.standard.StoreWriteTransactionImpl
 
close() - Method in interface com.swiftmq.impl.store.standard.swap.SwapFile
 
close() - Method in class com.swiftmq.impl.store.standard.swap.SwapFileImpl
 
close() - Method in interface com.swiftmq.impl.streams.comp.io.Input
Closes this Input.
close() - Method in class com.swiftmq.impl.streams.comp.io.MailServer
Closes this MailServer.
close() - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
 
close() - Method in class com.swiftmq.impl.streams.comp.io.Output
Closes this Output.
close() - Method in class com.swiftmq.impl.streams.comp.io.QueueInput
 
close() - Method in class com.swiftmq.impl.streams.comp.io.QueueWireTapInput
 
close() - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
 
close() - Method in class com.swiftmq.impl.streams.comp.jdbc.JDBCLookup
Closes the underlying JDBC connection.
close() - Method in class com.swiftmq.impl.streams.comp.log.Log
Internal use.
close() - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Closes this Memory.
close() - Method in class com.swiftmq.impl.streams.comp.memory.MemoryGroup
Closes this MemoryGroup.
close() - Method in class com.swiftmq.impl.streams.comp.timer.AtTimer
 
close() - Method in class com.swiftmq.impl.streams.comp.timer.IntervalTimer
 
close() - Method in class com.swiftmq.impl.streams.comp.timer.NextTimer
 
close() - Method in interface com.swiftmq.impl.streams.comp.timer.Timer
Closes this Timer.
close() - Method in class com.swiftmq.impl.streams.processor.StreamProcessor
 
close() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
close() - Method in class com.swiftmq.impl.streams.StreamController
 
close() - Method in class com.swiftmq.impl.streams.StreamLibDeployer
 
close() - Method in class com.swiftmq.impl.threadpool.standard.group.EventLoopImpl
 
close() - Method in class com.swiftmq.impl.threadpool.standard.group.Group
 
close() - Method in class com.swiftmq.impl.threadpool.standard.group.GroupRegistry
 
close() - Method in class com.swiftmq.impl.topic.standard.announce.TopicAnnounceSender
 
close() - Method in class com.swiftmq.impl.xa.standard.HeuristicHandler
 
close() - Method in class com.swiftmq.impl.xa.standard.XALiveContextImpl
 
close() - Method in class com.swiftmq.impl.xa.standard.XARecoveryContextImpl
 
close(ActiveLogin) - Method in class com.swiftmq.impl.mqtt.pubsub.Subscription
 
Close - Class in com.swiftmq.impl.mgmt.standard.po
 
Close - Class in com.swiftmq.impl.scheduler.standard.po
 
Close - Class in com.swiftmq.impl.store.standard.processor.backup.po
 
Close - Class in com.swiftmq.impl.store.standard.processor.scan.po
 
Close - Class in com.swiftmq.impl.store.standard.processor.shrink.po
 
Close(Semaphore) - Constructor for class com.swiftmq.impl.mgmt.standard.po.Close
 
Close(Semaphore) - Constructor for class com.swiftmq.impl.scheduler.standard.po.Close
 
Close(Semaphore) - Constructor for class com.swiftmq.impl.store.standard.processor.backup.po.Close
 
Close(Semaphore) - Constructor for class com.swiftmq.impl.store.standard.processor.scan.po.Close
 
Close(Semaphore) - Constructor for class com.swiftmq.impl.store.standard.processor.shrink.po.Close
 
CLOSE_STAGE_QUEUE_REQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.SMQRFactory
 
closeBrowser(CloseBrowserRequest) - Method in class com.swiftmq.impl.jms.standard.v750.BrowserManager
 
closed - Variable in class com.swiftmq.impl.jms.standard.v750.Session
 
closed - Variable in class com.swiftmq.impl.streams.Stream
 
CloseListener - Interface in com.swiftmq.impl.threadpool.standard.group
 
CloseLogOperation - Class in com.swiftmq.impl.store.standard.log
 
CloseLogOperation(Semaphore) - Constructor for class com.swiftmq.impl.store.standard.log.CloseLogOperation
 
closeNoDelete() - Method in interface com.swiftmq.impl.store.standard.swap.SwapFile
 
closeNoDelete() - Method in class com.swiftmq.impl.store.standard.swap.SwapFileImpl
 
closePreviousStage() - Method in class com.swiftmq.impl.routing.single.connection.stage.StageQueue
 
closeResource() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
closeResource() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
closeResource() - Method in interface com.swiftmq.impl.amqp.amqp.v01_00_00.transaction.ResourceProvider
 
closeSpaceResources() - Method in class com.swiftmq.impl.trace.standard.TraceSpaceImpl
 
CloseStageQueueRequest - Class in com.swiftmq.impl.routing.single.smqpr
 
CloseStageQueueRequest() - Constructor for class com.swiftmq.impl.routing.single.smqpr.CloseStageQueueRequest
 
CLUSTER_TOPIC - Static variable in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
CLUSTERED_QUEUE_METRIC - Static variable in class com.swiftmq.impl.queue.standard.cluster.v700.MetricFactory
 
CLUSTERED_QUEUE_METRIC_COLLECTION - Static variable in class com.swiftmq.impl.queue.standard.cluster.v700.MetricFactory
 
ClusteredQueue - Class in com.swiftmq.impl.queue.standard.cluster
 
ClusteredQueue(SwiftletContext, DispatchPolicy) - Constructor for class com.swiftmq.impl.queue.standard.cluster.ClusteredQueue
 
clusteredQueueFactory - Variable in class com.swiftmq.impl.queue.standard.SwiftletContext
 
ClusteredQueueFactory - Class in com.swiftmq.impl.queue.standard.cluster
 
ClusteredQueueFactory(SwiftletContext) - Constructor for class com.swiftmq.impl.queue.standard.cluster.ClusteredQueueFactory
 
ClusteredQueueFlowController - Class in com.swiftmq.impl.queue.standard.cluster
 
ClusteredQueueFlowController() - Constructor for class com.swiftmq.impl.queue.standard.cluster.ClusteredQueueFlowController
 
ClusteredQueueMetric - Interface in com.swiftmq.impl.queue.standard.cluster
 
ClusteredQueueMetricCollection - Interface in com.swiftmq.impl.queue.standard.cluster
 
ClusteredQueueMetricCollectionImpl - Class in com.swiftmq.impl.queue.standard.cluster.v700
 
ClusteredQueueMetricCollectionImpl() - Constructor for class com.swiftmq.impl.queue.standard.cluster.v700.ClusteredQueueMetricCollectionImpl
 
ClusteredQueueMetricCollectionImpl(String, List) - Constructor for class com.swiftmq.impl.queue.standard.cluster.v700.ClusteredQueueMetricCollectionImpl
 
ClusteredQueueMetricImpl - Class in com.swiftmq.impl.queue.standard.cluster.v700
 
ClusteredQueueMetricImpl() - Constructor for class com.swiftmq.impl.queue.standard.cluster.v700.ClusteredQueueMetricImpl
 
ClusteredQueueMetricImpl(String, List, boolean) - Constructor for class com.swiftmq.impl.queue.standard.cluster.v700.ClusteredQueueMetricImpl
 
ClusteredTransactionId - Class in com.swiftmq.impl.queue.standard.cluster
 
ClusteredTransactionId(SwiftletContext, boolean) - Constructor for class com.swiftmq.impl.queue.standard.cluster.ClusteredTransactionId
 
ClusteredTransactionId(SwiftletContext, AbstractQueue, Object, QueueImpl) - Constructor for class com.swiftmq.impl.queue.standard.cluster.ClusteredTransactionId
 
clusterMetricPublisher - Variable in class com.swiftmq.impl.queue.standard.SwiftletContext
 
ClusterMetricPublisher - Class in com.swiftmq.impl.queue.standard.cluster
 
ClusterMetricPublisher(SwiftletContext) - Constructor for class com.swiftmq.impl.queue.standard.cluster.ClusterMetricPublisher
 
clusterMetricSubscriber - Variable in class com.swiftmq.impl.queue.standard.SwiftletContext
 
ClusterMetricSubscriber - Class in com.swiftmq.impl.queue.standard.cluster
 
ClusterMetricSubscriber(SwiftletContext) - Constructor for class com.swiftmq.impl.queue.standard.cluster.ClusterMetricSubscriber
 
CodecException - Exception in com.swiftmq.impl.mqtt.v311.netty.handler.codec
An Exception which is thrown by a codec.
CodecException() - Constructor for exception com.swiftmq.impl.mqtt.v311.netty.handler.codec.CodecException
Creates a new instance.
CodecException(String) - Constructor for exception com.swiftmq.impl.mqtt.v311.netty.handler.codec.CodecException
Creates a new instance.
CodecException(String, Throwable) - Constructor for exception com.swiftmq.impl.mqtt.v311.netty.handler.codec.CodecException
Creates a new instance.
CodecException(Throwable) - Constructor for exception com.swiftmq.impl.mqtt.v311.netty.handler.codec.CodecException
Creates a new instance.
collect(long) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandler
 
collect(long) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.AMQPHandler
 
collect(long) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler
 
collect(long) - Method in interface com.swiftmq.impl.amqp.Handler
 
collect(long) - Method in class com.swiftmq.impl.amqp.sasl.v01_00_00.SASLHandler
 
collect(long) - Method in class com.swiftmq.impl.amqp.VersionedConnection
 
collect(long) - Method in class com.swiftmq.impl.jms.standard.v750.JMSConnection
 
collect(long) - Method in interface com.swiftmq.impl.jms.standard.VersionedJMSConnection
 
collect(long) - Method in class com.swiftmq.impl.mqtt.connection.MQTTConnection
 
collect(long) - Method in interface com.swiftmq.impl.streams.comp.io.Input
Internal use.
collect(long) - Method in class com.swiftmq.impl.streams.comp.io.MailServer
Internal use.
collect(long) - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
 
collect(long) - Method in class com.swiftmq.impl.streams.comp.io.Output
Internal use.
collect(long) - Method in class com.swiftmq.impl.streams.comp.io.QueueInput
 
collect(long) - Method in class com.swiftmq.impl.streams.comp.io.QueueWireTapInput
 
collect(long) - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
 
collect(long) - Method in class com.swiftmq.impl.streams.comp.jdbc.JDBCLookup
Internal use.
collect(long) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Internal use.
collect(long) - Method in class com.swiftmq.impl.streams.comp.timer.AtTimer
 
collect(long) - Method in class com.swiftmq.impl.streams.comp.timer.IntervalTimer
 
collect(long) - Method in class com.swiftmq.impl.streams.comp.timer.NextTimer
 
collect(long) - Method in interface com.swiftmq.impl.streams.comp.timer.Timer
Internal use
collect(long) - Method in class com.swiftmq.impl.streams.Stream
Internal use only
collect(long) - Method in class com.swiftmq.impl.streams.StreamController
 
collectByteCounts() - Method in class com.swiftmq.impl.net.netty.ConnectionManagerImpl
 
CollectRequest - Class in com.swiftmq.impl.jms.standard.v750
 
CollectRequest(long) - Constructor for class com.swiftmq.impl.jms.standard.v750.CollectRequest
 
com.swiftmq.impl.amqp - package com.swiftmq.impl.amqp
 
com.swiftmq.impl.amqp.amqp.v00_09_01 - package com.swiftmq.impl.amqp.amqp.v00_09_01
 
com.swiftmq.impl.amqp.amqp.v00_09_01.po - package com.swiftmq.impl.amqp.amqp.v00_09_01.po
 
com.swiftmq.impl.amqp.amqp.v00_09_01.transformer - package com.swiftmq.impl.amqp.amqp.v00_09_01.transformer
 
com.swiftmq.impl.amqp.amqp.v01_00_00 - package com.swiftmq.impl.amqp.amqp.v01_00_00
 
com.swiftmq.impl.amqp.amqp.v01_00_00.po - package com.swiftmq.impl.amqp.amqp.v01_00_00.po
 
com.swiftmq.impl.amqp.amqp.v01_00_00.transaction - package com.swiftmq.impl.amqp.amqp.v01_00_00.transaction
 
com.swiftmq.impl.amqp.amqp.v01_00_00.transformer - package com.swiftmq.impl.amqp.amqp.v01_00_00.transformer
 
com.swiftmq.impl.amqp.sasl.provider - package com.swiftmq.impl.amqp.sasl.provider
 
com.swiftmq.impl.amqp.sasl.v01_00_00 - package com.swiftmq.impl.amqp.sasl.v01_00_00
 
com.swiftmq.impl.amqp.sasl.v01_00_00.po - package com.swiftmq.impl.amqp.sasl.v01_00_00.po
 
com.swiftmq.impl.auth.standard - package com.swiftmq.impl.auth.standard
 
com.swiftmq.impl.deploy.standard - package com.swiftmq.impl.deploy.standard
 
com.swiftmq.impl.jms.standard - package com.swiftmq.impl.jms.standard
 
com.swiftmq.impl.jms.standard.v750 - package com.swiftmq.impl.jms.standard.v750
 
com.swiftmq.impl.jndi.standard - package com.swiftmq.impl.jndi.standard
 
com.swiftmq.impl.jndi.standard.v400 - package com.swiftmq.impl.jndi.standard.v400
 
com.swiftmq.impl.log.standard - package com.swiftmq.impl.log.standard
 
com.swiftmq.impl.mgmt.standard - package com.swiftmq.impl.mgmt.standard
 
com.swiftmq.impl.mgmt.standard.auth - package com.swiftmq.impl.mgmt.standard.auth
 
com.swiftmq.impl.mgmt.standard.jmx - package com.swiftmq.impl.mgmt.standard.jmx
 
com.swiftmq.impl.mgmt.standard.po - package com.swiftmq.impl.mgmt.standard.po
 
com.swiftmq.impl.mgmt.standard.v750 - package com.swiftmq.impl.mgmt.standard.v750
 
com.swiftmq.impl.mqtt - package com.swiftmq.impl.mqtt
 
com.swiftmq.impl.mqtt.connection - package com.swiftmq.impl.mqtt.connection
 
com.swiftmq.impl.mqtt.po - package com.swiftmq.impl.mqtt.po
 
com.swiftmq.impl.mqtt.pubsub - package com.swiftmq.impl.mqtt.pubsub
 
com.swiftmq.impl.mqtt.retain - package com.swiftmq.impl.mqtt.retain
 
com.swiftmq.impl.mqtt.session - package com.swiftmq.impl.mqtt.session
 
com.swiftmq.impl.mqtt.v311 - package com.swiftmq.impl.mqtt.v311
 
com.swiftmq.impl.mqtt.v311.netty.buffer - package com.swiftmq.impl.mqtt.v311.netty.buffer
 
com.swiftmq.impl.mqtt.v311.netty.handler.codec - package com.swiftmq.impl.mqtt.v311.netty.handler.codec
 
com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt - package com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt
 
com.swiftmq.impl.mqtt.v311.netty.util - package com.swiftmq.impl.mqtt.v311.netty.util
 
com.swiftmq.impl.mqtt.v311.netty.util.internal - package com.swiftmq.impl.mqtt.v311.netty.util.internal
 
com.swiftmq.impl.net.netty - package com.swiftmq.impl.net.netty
 
com.swiftmq.impl.net.netty.scheduler - package com.swiftmq.impl.net.netty.scheduler
 
com.swiftmq.impl.queue.standard - package com.swiftmq.impl.queue.standard
 
com.swiftmq.impl.queue.standard.cluster - package com.swiftmq.impl.queue.standard.cluster
 
com.swiftmq.impl.queue.standard.cluster.v700 - package com.swiftmq.impl.queue.standard.cluster.v700
 
com.swiftmq.impl.queue.standard.command - package com.swiftmq.impl.queue.standard.command
 
com.swiftmq.impl.queue.standard.composite - package com.swiftmq.impl.queue.standard.composite
 
com.swiftmq.impl.queue.standard.jobs - package com.swiftmq.impl.queue.standard.jobs
 
com.swiftmq.impl.queue.standard.queue - package com.swiftmq.impl.queue.standard.queue
 
com.swiftmq.impl.routing.single - package com.swiftmq.impl.routing.single
 
com.swiftmq.impl.routing.single.connection - package com.swiftmq.impl.routing.single.connection
 
com.swiftmq.impl.routing.single.connection.event - package com.swiftmq.impl.routing.single.connection.event
 
com.swiftmq.impl.routing.single.connection.stage - package com.swiftmq.impl.routing.single.connection.stage
 
com.swiftmq.impl.routing.single.connection.v942 - package com.swiftmq.impl.routing.single.connection.v942
 
com.swiftmq.impl.routing.single.jobs - package com.swiftmq.impl.routing.single.jobs
 
com.swiftmq.impl.routing.single.manager - package com.swiftmq.impl.routing.single.manager
 
com.swiftmq.impl.routing.single.manager.event - package com.swiftmq.impl.routing.single.manager.event
 
com.swiftmq.impl.routing.single.manager.po - package com.swiftmq.impl.routing.single.manager.po
 
com.swiftmq.impl.routing.single.route - package com.swiftmq.impl.routing.single.route
 
com.swiftmq.impl.routing.single.route.po - package com.swiftmq.impl.routing.single.route.po
 
com.swiftmq.impl.routing.single.route.v400 - package com.swiftmq.impl.routing.single.route.v400
 
com.swiftmq.impl.routing.single.schedule - package com.swiftmq.impl.routing.single.schedule
 
com.swiftmq.impl.routing.single.schedule.po - package com.swiftmq.impl.routing.single.schedule.po
 
com.swiftmq.impl.routing.single.smqpr - package com.swiftmq.impl.routing.single.smqpr
 
com.swiftmq.impl.routing.single.smqpr.v400 - package com.swiftmq.impl.routing.single.smqpr.v400
 
com.swiftmq.impl.routing.single.smqpr.v942 - package com.swiftmq.impl.routing.single.smqpr.v942
 
com.swiftmq.impl.routing.unlimited - package com.swiftmq.impl.routing.unlimited
 
com.swiftmq.impl.scheduler.standard - package com.swiftmq.impl.scheduler.standard
 
com.swiftmq.impl.scheduler.standard.job - package com.swiftmq.impl.scheduler.standard.job
 
com.swiftmq.impl.scheduler.standard.po - package com.swiftmq.impl.scheduler.standard.po
 
com.swiftmq.impl.store.standard - package com.swiftmq.impl.store.standard
 
com.swiftmq.impl.store.standard.cache - package com.swiftmq.impl.store.standard.cache
 
com.swiftmq.impl.store.standard.index - package com.swiftmq.impl.store.standard.index
 
com.swiftmq.impl.store.standard.jobs - package com.swiftmq.impl.store.standard.jobs
 
com.swiftmq.impl.store.standard.log - package com.swiftmq.impl.store.standard.log
 
com.swiftmq.impl.store.standard.pagedb - package com.swiftmq.impl.store.standard.pagedb
 
com.swiftmq.impl.store.standard.processor.backup - package com.swiftmq.impl.store.standard.processor.backup
 
com.swiftmq.impl.store.standard.processor.backup.po - package com.swiftmq.impl.store.standard.processor.backup.po
 
com.swiftmq.impl.store.standard.processor.scan - package com.swiftmq.impl.store.standard.processor.scan
 
com.swiftmq.impl.store.standard.processor.scan.po - package com.swiftmq.impl.store.standard.processor.scan.po
 
com.swiftmq.impl.store.standard.processor.shrink - package com.swiftmq.impl.store.standard.processor.shrink
 
com.swiftmq.impl.store.standard.processor.shrink.po - package com.swiftmq.impl.store.standard.processor.shrink.po
 
com.swiftmq.impl.store.standard.recover - package com.swiftmq.impl.store.standard.recover
 
com.swiftmq.impl.store.standard.swap - package com.swiftmq.impl.store.standard.swap
 
com.swiftmq.impl.store.standard.transaction - package com.swiftmq.impl.store.standard.transaction
 
com.swiftmq.impl.store.standard.xa - package com.swiftmq.impl.store.standard.xa
 
com.swiftmq.impl.streams - package com.swiftmq.impl.streams
 
com.swiftmq.impl.streams.comp.io - package com.swiftmq.impl.streams.comp.io
 
com.swiftmq.impl.streams.comp.jdbc - package com.swiftmq.impl.streams.comp.jdbc
 
com.swiftmq.impl.streams.comp.log - package com.swiftmq.impl.streams.comp.log
 
com.swiftmq.impl.streams.comp.management - package com.swiftmq.impl.streams.comp.management
 
com.swiftmq.impl.streams.comp.memory - package com.swiftmq.impl.streams.comp.memory
 
com.swiftmq.impl.streams.comp.memory.limit - package com.swiftmq.impl.streams.comp.memory.limit
 
com.swiftmq.impl.streams.comp.message - package com.swiftmq.impl.streams.comp.message
 
com.swiftmq.impl.streams.comp.timer - package com.swiftmq.impl.streams.comp.timer
 
com.swiftmq.impl.streams.graalvm - package com.swiftmq.impl.streams.graalvm
 
com.swiftmq.impl.streams.jobs - package com.swiftmq.impl.streams.jobs
 
com.swiftmq.impl.streams.processor - package com.swiftmq.impl.streams.processor
 
com.swiftmq.impl.streams.processor.po - package com.swiftmq.impl.streams.processor.po
 
com.swiftmq.impl.threadpool.standard - package com.swiftmq.impl.threadpool.standard
 
com.swiftmq.impl.threadpool.standard.group - package com.swiftmq.impl.threadpool.standard.group
 
com.swiftmq.impl.threadpool.standard.group.pool - package com.swiftmq.impl.threadpool.standard.group.pool
 
com.swiftmq.impl.timer.standard - package com.swiftmq.impl.timer.standard
 
com.swiftmq.impl.topic.standard - package com.swiftmq.impl.topic.standard
 
com.swiftmq.impl.topic.standard.announce - package com.swiftmq.impl.topic.standard.announce
 
com.swiftmq.impl.topic.standard.announce.po - package com.swiftmq.impl.topic.standard.announce.po
 
com.swiftmq.impl.topic.standard.announce.v400 - package com.swiftmq.impl.topic.standard.announce.v400
 
com.swiftmq.impl.topic.standard.jobs - package com.swiftmq.impl.topic.standard.jobs
 
com.swiftmq.impl.trace.standard - package com.swiftmq.impl.trace.standard
 
com.swiftmq.impl.xa.standard - package com.swiftmq.impl.xa.standard
 
commit() - Method in class com.swiftmq.impl.mqtt.pubsub.Producer
 
commit() - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredTransactionId
 
commit() - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
commit() - Method in class com.swiftmq.impl.store.standard.StoreReadTransactionImpl
 
commit() - Method in class com.swiftmq.impl.store.standard.StoreTransactionImpl
 
commit() - Method in class com.swiftmq.impl.topic.standard.TopicSubscriberTransaction
 
commit() - Method in class com.swiftmq.impl.topic.standard.TopicTransaction
 
commit(boolean) - Method in class com.swiftmq.impl.xa.standard.XALiveContextImpl
 
commit(boolean) - Method in class com.swiftmq.impl.xa.standard.XARecoveryContextImpl
 
commit(AsyncCompletionCallback) - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredTransactionId
 
commit(AsyncCompletionCallback) - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
commit(AsyncCompletionCallback) - Method in class com.swiftmq.impl.store.standard.StoreReadTransactionImpl
 
commit(AsyncCompletionCallback) - Method in class com.swiftmq.impl.store.standard.StoreTransactionImpl
 
commit(AsyncCompletionCallback) - Method in class com.swiftmq.impl.topic.standard.TopicSubscriberTransaction
 
commit(AsyncCompletionCallback) - Method in class com.swiftmq.impl.topic.standard.TopicTransaction
 
commit(CommitLogRecord) - Method in class com.swiftmq.impl.store.standard.recover.RecoveryManager
 
commit(Object) - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredQueue
 
commit(Object) - Method in class com.swiftmq.impl.queue.standard.composite.CompositeQueue
 
commit(Object) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
commit(Object) - Method in class com.swiftmq.impl.topic.standard.TopicBroker
Commit the transaction with the given transaction id
commit(Object, AsyncCompletionCallback) - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredQueue
 
commit(Object, AsyncCompletionCallback) - Method in class com.swiftmq.impl.queue.standard.composite.CompositeQueue
 
commit(Object, AsyncCompletionCallback) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
commit(Object, AsyncCompletionCallback) - Method in class com.swiftmq.impl.topic.standard.TopicBroker
 
commit(Object, XidImpl) - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredQueue
 
commit(Object, XidImpl) - Method in class com.swiftmq.impl.queue.standard.composite.CompositeQueue
 
commit(Object, XidImpl) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
commit(Object, XidImpl) - Method in class com.swiftmq.impl.topic.standard.TopicBroker
 
commit(XidImpl) - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredTransactionId
 
commit(XidImpl) - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
commit(XidImpl) - Method in class com.swiftmq.impl.store.standard.StoreReadTransactionImpl
 
commit(XidImpl) - Method in class com.swiftmq.impl.store.standard.StoreWriteTransactionImpl
 
commit(XidImpl) - Method in class com.swiftmq.impl.topic.standard.TopicSubscriberTransaction
 
commit(XidImpl) - Method in class com.swiftmq.impl.topic.standard.TopicTransaction
 
commit(XidImpl) - Method in class com.swiftmq.impl.xa.standard.XAResourceManagerSwiftletImpl
 
COMMIT - Static variable in class com.swiftmq.impl.store.standard.log.LogRecord
 
COMMIT_REPREQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v400.SMQRFactory
 
COMMIT_REPREQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v942.SMQRFactory
 
COMMIT_REQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v400.SMQRFactory
 
COMMIT_REQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v942.SMQRFactory
 
CommitLogRecord - Class in com.swiftmq.impl.store.standard.log
 
CommitLogRecord(long, Semaphore, List, CacheReleaseListener, AsyncCompletionCallback, List) - Constructor for class com.swiftmq.impl.store.standard.log.CommitLogRecord
 
CommitLogRecord(long, Semaphore, List, CacheReleaseListener, List) - Constructor for class com.swiftmq.impl.store.standard.log.CommitLogRecord
 
CommitReplyRequest - Class in com.swiftmq.impl.routing.single.smqpr.v400
 
CommitReplyRequest - Class in com.swiftmq.impl.routing.single.smqpr.v942
 
CommitReplyRequest() - Constructor for class com.swiftmq.impl.routing.single.smqpr.v400.CommitReplyRequest
 
CommitReplyRequest() - Constructor for class com.swiftmq.impl.routing.single.smqpr.v942.CommitReplyRequest
 
CommitReplyRequest(XidImpl) - Constructor for class com.swiftmq.impl.routing.single.smqpr.v400.CommitReplyRequest
 
CommitReplyRequest(XidImpl) - Constructor for class com.swiftmq.impl.routing.single.smqpr.v942.CommitReplyRequest
 
CommitRequest - Class in com.swiftmq.impl.routing.single.smqpr.v400
 
CommitRequest - Class in com.swiftmq.impl.routing.single.smqpr.v942
 
CommitRequest(XidImpl) - Constructor for class com.swiftmq.impl.routing.single.smqpr.v400.CommitRequest
 
CommitRequest(XidImpl) - Constructor for class com.swiftmq.impl.routing.single.smqpr.v942.CommitRequest
 
commitTransaction() - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
commitTransaction(AsyncCompletionCallback) - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
commitTransactions() - Method in class com.swiftmq.impl.streams.StreamContext
 
commitTransactionsGlobalLock() - Method in class com.swiftmq.impl.streams.StreamContext
 
commitTransactionsNoGlobalLock() - Method in class com.swiftmq.impl.streams.StreamContext
 
compareTo(Signal) - Method in error com.swiftmq.impl.mqtt.v311.netty.util.Signal
 
compareTo(Object) - Method in class com.swiftmq.impl.store.standard.cache.Slot
 
compareTo(Object) - Method in class com.swiftmq.impl.topic.standard.DurableSubscription
 
compareTo(T) - Method in class com.swiftmq.impl.mqtt.v311.netty.util.AbstractConstant
 
CompositeQueue - Class in com.swiftmq.impl.queue.standard.composite
 
CompositeQueue(SwiftletContext, Entity) - Constructor for class com.swiftmq.impl.queue.standard.composite.CompositeQueue
 
compositeQueueFactory - Variable in class com.swiftmq.impl.queue.standard.SwiftletContext
 
CompositeQueueFactory - Class in com.swiftmq.impl.queue.standard.composite
 
CompositeQueueFactory(SwiftletContext) - Constructor for class com.swiftmq.impl.queue.standard.composite.CompositeQueueFactory
 
CompositeQueueFlowController - Class in com.swiftmq.impl.queue.standard.composite
 
CompositeQueueFlowController() - Constructor for class com.swiftmq.impl.queue.standard.composite.CompositeQueueFlowController
 
CompositeStoreTransactionImpl - Class in com.swiftmq.impl.store.standard
 
CompositeStoreTransactionImpl(StoreContext) - Constructor for class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
CompositeTransactionId - Class in com.swiftmq.impl.queue.standard.composite
 
CompositeTransactionId() - Constructor for class com.swiftmq.impl.queue.standard.composite.CompositeTransactionId
 
CompositeTransactionIdEntry - Class in com.swiftmq.impl.queue.standard.composite
 
CompositeTransactionIdEntry(boolean, AbstractQueue, Object, MessageSelector, boolean, boolean, boolean, String) - Constructor for class com.swiftmq.impl.queue.standard.composite.CompositeTransactionIdEntry
 
concatName(String[]) - Static method in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
config - Variable in class com.swiftmq.impl.amqp.SwiftletContext
 
config - Variable in class com.swiftmq.impl.deploy.standard.SwiftletContext
 
config - Variable in class com.swiftmq.impl.jms.standard.SwiftletContext
 
config - Variable in class com.swiftmq.impl.jndi.standard.SwiftletContext
 
config - Variable in class com.swiftmq.impl.mqtt.SwiftletContext
 
config - Variable in class com.swiftmq.impl.net.netty.SwiftletContext
 
config - Variable in class com.swiftmq.impl.queue.standard.SwiftletContext
 
config - Variable in class com.swiftmq.impl.routing.single.RoutingSwiftletImpl
 
config - Variable in class com.swiftmq.impl.store.standard.StoreContext
 
config - Variable in class com.swiftmq.impl.streams.SwiftletContext
 
config - Variable in class com.swiftmq.impl.threadpool.standard.SwiftletContext
 
config - Variable in class com.swiftmq.impl.xa.standard.SwiftletContext
 
connAck() - Static method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageBuilders
 
CONNACK - Enum constant in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageType
 
connect() - Method in class com.swiftmq.impl.jndi.standard.JNDIReplication
 
connect() - Static method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageBuilders
 
connect() - Method in class com.swiftmq.impl.net.netty.scheduler.NettyTCPConnector
 
connect() - Method in class com.swiftmq.impl.net.netty.scheduler.TCPConnector
 
connect() - Method in class com.swiftmq.impl.streams.comp.io.MailServer
Does the actual connect to the mail server.
connect() - Method in class com.swiftmq.impl.streams.comp.jdbc.JDBCLookup
Performs a connect to the database.
CONNECT - Enum constant in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageType
 
CONNECT_REPREQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v400.SMQRFactory
 
CONNECT_REPREQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v942.SMQRFactory
 
CONNECT_REQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v400.SMQRFactory
 
CONNECT_REQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.v942.SMQRFactory
 
connectIntraVMListener(String, IntraVMConnection) - Method in class com.swiftmq.impl.net.netty.NetworkSwiftletImpl
 
CONNECTION_ACCEPTED - Enum constant in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnectReturnCode
 
CONNECTION_REFUSED_BAD_USER_NAME_OR_PASSWORD - Enum constant in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnectReturnCode
 
CONNECTION_REFUSED_IDENTIFIER_REJECTED - Enum constant in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnectReturnCode
 
CONNECTION_REFUSED_NOT_AUTHORIZED - Enum constant in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnectReturnCode
 
CONNECTION_REFUSED_SERVER_UNAVAILABLE - Enum constant in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnectReturnCode
 
CONNECTION_REFUSED_UNACCEPTABLE_PROTOCOL_VERSION - Enum constant in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnectReturnCode
 
connectionAdded(RoutingConnection) - Method in class com.swiftmq.impl.routing.single.schedule.Scheduler
 
connectionAdded(ConnectionEvent) - Method in interface com.swiftmq.impl.routing.single.manager.event.ConnectionListener
 
connectionAdded(ConnectionEvent) - Method in class com.swiftmq.impl.routing.single.route.RouteExchanger
 
ConnectionEndException - Exception in com.swiftmq.impl.amqp.amqp.v01_00_00
 
ConnectionEndException(ErrorConditionIF, AMQPString) - Constructor for exception com.swiftmq.impl.amqp.amqp.v01_00_00.ConnectionEndException
 
ConnectionEntry(RoutingConnection) - Constructor for class com.swiftmq.impl.routing.single.schedule.DefaultScheduler.ConnectionEntry
 
ConnectionEvent - Class in com.swiftmq.impl.routing.single.manager.event
 
ConnectionEvent(RoutingConnection) - Constructor for class com.swiftmq.impl.routing.single.manager.event.ConnectionEvent
 
connectionId - Variable in class com.swiftmq.impl.jms.standard.v750.JMSConnection
 
ConnectionListener - Interface in com.swiftmq.impl.routing.single.manager.event
 
connectionManager - Variable in class com.swiftmq.impl.routing.single.SwiftletContext
 
ConnectionManager - Class in com.swiftmq.impl.routing.single.manager
 
ConnectionManager(SwiftletContext) - Constructor for class com.swiftmq.impl.routing.single.manager.ConnectionManager
 
ConnectionManagerImpl - Class in com.swiftmq.impl.net.netty
 
ConnectionManagerImpl(SwiftletContext) - Constructor for class com.swiftmq.impl.net.netty.ConnectionManagerImpl
 
connectionRemoved(RoutingConnection) - Method in class com.swiftmq.impl.routing.single.schedule.Scheduler
 
connectionRemoved(ConnectionEvent) - Method in interface com.swiftmq.impl.routing.single.manager.event.ConnectionListener
 
connectionRemoved(ConnectionEvent) - Method in class com.swiftmq.impl.routing.single.route.RouteExchanger
 
connections - Variable in class com.swiftmq.impl.routing.single.manager.ConnectionManager
 
ConnectionVisitorAdapter - Class in com.swiftmq.impl.jms.standard.v750
 
ConnectionVisitorAdapter() - Constructor for class com.swiftmq.impl.jms.standard.v750.ConnectionVisitorAdapter
 
connectListener(String, IntraVMConnection) - Method in class com.swiftmq.impl.net.netty.scheduler.IntraVMScheduler
 
connectLoggingEnabled - Variable in class com.swiftmq.impl.mgmt.standard.SwiftletContext
 
ConnectReplyRequest - Class in com.swiftmq.impl.routing.single.smqpr.v400
 
ConnectReplyRequest - Class in com.swiftmq.impl.routing.single.smqpr.v942
 
ConnectReplyRequest() - Constructor for class com.swiftmq.impl.routing.single.smqpr.v400.ConnectReplyRequest
 
ConnectReplyRequest() - Constructor for class com.swiftmq.impl.routing.single.smqpr.v942.ConnectReplyRequest
 
ConnectRequest - Class in com.swiftmq.impl.routing.single.smqpr.v400
 
ConnectRequest - Class in com.swiftmq.impl.routing.single.smqpr.v942
 
ConnectRequest(String) - Constructor for class com.swiftmq.impl.routing.single.smqpr.v400.ConnectRequest
 
ConnectRequest(String, boolean) - Constructor for class com.swiftmq.impl.routing.single.smqpr.v942.ConnectRequest
 
connectReturnCode() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnAckVariableHeader
 
ConnectStage - Class in com.swiftmq.impl.routing.single.connection.v942
 
ConnectStage(SwiftletContext, RoutingConnection) - Constructor for class com.swiftmq.impl.routing.single.connection.v942.ConnectStage
 
Constant<T extends Constant<T>> - Interface in com.swiftmq.impl.mqtt.v311.netty.util
A singleton which is safe to compare via the == operator.
ConstantPool<T extends Constant<T>> - Class in com.swiftmq.impl.mqtt.v311.netty.util
A pool of Constants.
ConstantPool() - Constructor for class com.swiftmq.impl.mqtt.v311.netty.util.ConstantPool
 
Consumer - Class in com.swiftmq.impl.amqp.amqp.v00_09_01
 
Consumer - Class in com.swiftmq.impl.jms.standard.v750
 
Consumer - Class in com.swiftmq.impl.mqtt.pubsub
 
Consumer(SwiftletContext, ChannelHandler, String, String, String, boolean, boolean) - Constructor for class com.swiftmq.impl.amqp.amqp.v00_09_01.Consumer
 
Consumer(SessionContext) - Constructor for class com.swiftmq.impl.jms.standard.v750.Consumer
 
Consumer(SwiftletContext, MQTTSession, String, int) - Constructor for class com.swiftmq.impl.mqtt.pubsub.Consumer
 
consumerCacheLowWaterMark - Variable in class com.swiftmq.impl.jms.standard.SwiftletContext
 
consumerList - Variable in class com.swiftmq.impl.jms.standard.v750.Session
 
consumerModeInt(String) - Method in class com.swiftmq.impl.queue.standard.SwiftletContext
 
content() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttPublishMessage
 
ContentTransformer - Class in com.swiftmq.impl.streams
 
ContentTransformer() - Constructor for class com.swiftmq.impl.streams.ContentTransformer
 
context() - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
Returns the CLI context
context(ClassLoader) - Static method in class com.swiftmq.impl.streams.graalvm.GraalSetup
 
context(String) - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
Sets a CLI context different from the name.
contextJson(String) - Method in class com.swiftmq.impl.streams.comp.management.CLI
Returns the JSON output of the CLI context which must point to an Entity or EntityList.
convert(Route, String) - Method in class com.swiftmq.impl.routing.single.route.RouteConverter
 
convert(VersionedDumpable, int) - Method in class com.swiftmq.impl.topic.standard.announce.TopicInfoConverter
 
convert(VersionedDumpable, int[]) - Method in class com.swiftmq.impl.topic.standard.announce.TopicInfoConverter
 
Copier - Class in com.swiftmq.impl.queue.standard.command
 
Copier(SwiftletContext) - Constructor for class com.swiftmq.impl.queue.standard.command.Copier
 
copy() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttPublishMessage
 
copy() - Method in class com.swiftmq.impl.store.standard.cache.Page
 
copy(int) - Method in class com.swiftmq.impl.store.standard.cache.Page
 
copy(String) - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
copy(String) - Method in class com.swiftmq.impl.store.standard.DurableSubscriberStoreImpl
 
copyMessage(Message) - Method in class com.swiftmq.impl.streams.comp.message.MessageBuilder
Internal use only.
copyProperties(Message) - Method in class com.swiftmq.impl.streams.comp.message.Message
Internal use only.
copyToNewSize(String, String, int, int) - Static method in class com.swiftmq.impl.store.standard.cache.StableStore
 
correlationId() - Method in class com.swiftmq.impl.streams.comp.message.Message
Returns the JMS correlation ID.
correlationId(String) - Method in class com.swiftmq.impl.streams.comp.message.Message
Sets the JMS correlation ID.
count(int) - Method in class com.swiftmq.impl.streams.comp.memory.limit.LimitBuilder
Returns a new CountLimit.
Countable - Interface in com.swiftmq.impl.net.netty
 
CountableBufferedInputStream - Class in com.swiftmq.impl.net.netty
 
CountableBufferedInputStream(InputStream) - Constructor for class com.swiftmq.impl.net.netty.CountableBufferedInputStream
 
CountableBufferedOutputStream - Class in com.swiftmq.impl.net.netty
 
CountableBufferedOutputStream(ProtocolOutputHandler, SocketChannel) - Constructor for class com.swiftmq.impl.net.netty.CountableBufferedOutputStream
 
CountableInput - Class in com.swiftmq.impl.net.netty
 
CountableInput() - Constructor for class com.swiftmq.impl.net.netty.CountableInput
 
CountableWrappedOutputStream - Class in com.swiftmq.impl.net.netty
 
CountableWrappedOutputStream(OutputStream) - Constructor for class com.swiftmq.impl.net.netty.CountableWrappedOutputStream
 
CountLimit - Class in com.swiftmq.impl.streams.comp.memory.limit
A CountLimit keeps a Memory at a specific number of Messages and removes older Messages if necessary.
create() - Method in interface com.swiftmq.impl.amqp.amqp.v00_09_01.ExchangeFactory
 
create() - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
create() - Method in class com.swiftmq.impl.streams.Stream
Returns a stream builder to create stream resources
create(int) - Static method in class com.swiftmq.impl.store.standard.log.LogAction
 
create(int) - Static method in class com.swiftmq.impl.store.standard.log.LogRecord
 
create(AddressIF) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
create(AddressIF) - Method in interface com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.DestinationFactory
 
create(AMQPMessage) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.BodyTypeMessageFactory
 
create(AMQPMessage) - Method in interface com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.MessageFactory
 
create(SwiftletContext, Entity, String, DispatchPolicy) - Method in interface com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicyFactory
 
create(SwiftletContext, Entity, String, DispatchPolicy) - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicyFactoryImpl
 
create(Comparable) - Method in interface com.swiftmq.impl.streams.comp.memory.MemoryCreateCallback
Create a new Memory
create(String) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.ChannelHandler
 
create(String) - Method in interface com.swiftmq.impl.amqp.amqp.v00_09_01.transformer.DestinationFactory
 
createAndPin() - Method in class com.swiftmq.impl.store.standard.cache.CacheManager
 
createBody(MessageImpl, AMQPMessage) - Method in interface com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.BodyFactory
 
createBody(MessageImpl, AMQPMessage) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.MessageTypeBodyFactory
 
createBrowser(CreateBrowserRequest) - Method in class com.swiftmq.impl.jms.standard.v750.BrowserManager
 
createCacheTable(String, int) - Method in interface com.swiftmq.impl.queue.standard.queue.CacheTableFactory
 
createCacheTable(String, int) - Method in class com.swiftmq.impl.queue.standard.queue.CacheTableFactoryImpl
 
createCacheTableFactory() - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
createCalendar(SwiftletContext, Entity) - Static method in class com.swiftmq.impl.scheduler.standard.CalendarFactory
 
createClientContext() - Static method in class com.swiftmq.impl.net.netty.SSLContextFactory
 
createCLIExecutor() - Method in class com.swiftmq.impl.mgmt.standard.MgmtSwiftletImpl
 
createCommand() - Method in class com.swiftmq.impl.queue.standard.command.Activate
 
createCommand() - Method in class com.swiftmq.impl.queue.standard.command.Copier
 
createCommand() - Method in class com.swiftmq.impl.queue.standard.command.Exporter
 
createCommand() - Method in class com.swiftmq.impl.queue.standard.command.Importer
 
createCommand() - Method in class com.swiftmq.impl.queue.standard.command.Remover
 
createCommand() - Method in class com.swiftmq.impl.queue.standard.command.Resetter
 
createCommand() - Method in class com.swiftmq.impl.queue.standard.command.Viewer
 
createCompositeStoreTransaction() - Method in class com.swiftmq.impl.store.standard.StoreSwiftletImpl
 
createConnectionManager() - Method in class com.swiftmq.impl.routing.single.SwiftletContext
 
createConnectionManager() - Method in class com.swiftmq.impl.routing.unlimited.USwiftletContext
 
createConnector(ConnectorMetaData) - Method in class com.swiftmq.impl.net.netty.scheduler.IOScheduler
 
createConnectorInstance(ConnectorMetaData, SocketFactory) - Method in class com.swiftmq.impl.net.netty.scheduler.IOScheduler
 
createConnectorInstance(ConnectorMetaData, SocketFactory) - Method in class com.swiftmq.impl.net.netty.scheduler.NettyIOScheduler
 
createCopy() - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
createCopy() - Method in class com.swiftmq.impl.scheduler.standard.SchedulerCalendar
 
createDumpable(int) - Method in class com.swiftmq.impl.queue.standard.cluster.v700.MetricFactory
 
createDumpable(int) - Method in class com.swiftmq.impl.routing.single.route.RouteConverter
 
createDumpable(int) - Method in class com.swiftmq.impl.routing.single.smqpr.SMQRFactory
 
createDumpable(int) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.SMQRFactory
 
createDumpable(int) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.SMQRFactory
 
createDumpable(Versioned) - Method in class com.swiftmq.impl.topic.standard.announce.TopicInfoFactory
 
createDuplicateTransaction() - Method in class com.swiftmq.impl.jms.standard.v750.Consumer
 
createDurableQueueName(String, String) - Static method in class com.swiftmq.impl.topic.standard.DurableSubscription
 
createDurableSubscriberStore(StoreContext, String) - Method in class com.swiftmq.impl.store.standard.StoreSwiftletImpl
 
createEventLoop(String, EventProcessor) - Method in class com.swiftmq.impl.threadpool.standard.ThreadpoolSwiftletImpl
 
createFirstStage(SwiftletContext, RoutingConnection, String) - Static method in class com.swiftmq.impl.routing.single.connection.stage.StageFactory
 
createHandler(VersionedConnection) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandlerFactory
 
createHandler(VersionedConnection) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.AMQPHandlerFactory
 
createHandler(VersionedConnection) - Method in interface com.swiftmq.impl.amqp.HandlerFactory
 
createHandler(VersionedConnection) - Method in class com.swiftmq.impl.amqp.sasl.v01_00_00.SASLHandlerFactory
 
createInboundTransformer(long, String) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.TransformerFactory
 
createIndex(String) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Creates an Index over a Property
createIndexEntry() - Method in class com.swiftmq.impl.store.standard.index.IndexPage
 
createIndexEntry() - Method in class com.swiftmq.impl.store.standard.index.QueueIndexPage
 
createIndexEntry() - Method in class com.swiftmq.impl.store.standard.index.RootIndexPage
 
createIndexPage(int) - Method in class com.swiftmq.impl.store.standard.index.Index
 
createIndexPage(int) - Method in class com.swiftmq.impl.store.standard.index.QueueIndex
 
createIndexPage(int) - Method in class com.swiftmq.impl.store.standard.index.RootIndex
 
createIntraVMListener(IntraVMListenerMetaData) - Method in class com.swiftmq.impl.net.netty.NetworkSwiftletImpl
 
createJMSConnection(int, Entity, Connection) - Method in class com.swiftmq.impl.jms.standard.JMSSwiftlet
 
createListener(IntraVMListenerMetaData) - Method in class com.swiftmq.impl.net.netty.scheduler.IntraVMScheduler
 
createListener(ListenerMetaData) - Method in class com.swiftmq.impl.net.netty.scheduler.IOScheduler
 
createListenerInstance(ListenerMetaData, SocketFactory) - Method in class com.swiftmq.impl.net.netty.scheduler.IOScheduler
 
createListenerInstance(ListenerMetaData, SocketFactory) - Method in class com.swiftmq.impl.net.netty.scheduler.NettyIOScheduler
 
createLocalCallback(AsyncCompletionCallback) - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
createLocalCallback(AsyncCompletionCallback) - Method in class com.swiftmq.impl.store.standard.StoreTransactionImpl
 
createLoginId(String) - Method in class com.swiftmq.impl.auth.standard.AuthenticationSwiftletImpl
 
createLogManager(StoreContext, CheckPointHandler, String, long, boolean) - Method in interface com.swiftmq.impl.store.standard.log.LogManagerFactory
 
createLogManager(StoreContext, CheckPointHandler, String, long, boolean) - Method in class com.swiftmq.impl.store.standard.log.LogManagerFactoryImpl
 
createLogManagerFactory() - Method in class com.swiftmq.impl.store.standard.StoreSwiftletImpl
 
createLogSink(String) - Method in class com.swiftmq.impl.log.standard.LogSwiftletImpl
 
createMessaageGroupDispatchPolicyFactory() - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
createMessageQueue(SwiftletContext, String, Cache, PersistentStore, NonPersistentStore, long) - Method in interface com.swiftmq.impl.queue.standard.queue.MessageQueueFactory
 
createMessageQueue(SwiftletContext, String, Cache, PersistentStore, NonPersistentStore, long) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueueFactoryImpl
 
createMessageQueueFactory() - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
createNewGroupEntry(Object) - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
createNonPersistentStore(StoreContext, String, String, long) - Method in class com.swiftmq.impl.store.standard.StoreSwiftletImpl
 
createOutboundTransformer(long, String) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.TransformerFactory
 
createPage(int) - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
createPullTransaction() - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredQueue
 
createPullTransaction() - Method in class com.swiftmq.impl.queue.standard.composite.CompositeQueue
 
createPullTransaction() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
createPullTransaction() - Method in class com.swiftmq.impl.topic.standard.TopicBroker
Creates a new pull transaction and returns a unique transaction id
createPushTransaction() - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredQueue
 
createPushTransaction() - Method in class com.swiftmq.impl.queue.standard.composite.CompositeQueue
 
createPushTransaction() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
createPushTransaction() - Method in class com.swiftmq.impl.topic.standard.TopicBroker
Creates a new push transaction and returns a unique transaction id
createQueue(String, ActiveLogin) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
createQueue(String, Entity) - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredQueueFactory
 
createQueue(String, Entity) - Method in class com.swiftmq.impl.queue.standard.composite.CompositeQueueFactory
 
createQueue(String, Entity) - Method in class com.swiftmq.impl.queue.standard.queue.RegularQueueFactory
 
createQueue(String, Entity) - Method in class com.swiftmq.impl.queue.standard.queue.SystemQueueFactory
 
createQueue(String, Entity) - Method in class com.swiftmq.impl.queue.standard.queue.TempQueueFactory
 
createQueue(String, Entity) - Method in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
createQueue(String, QueueFactory) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
createQueueBrowser(String, ActiveLogin, Selector) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
createQueueReceiver(String, ActiveLogin, Selector) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
createQueueSender(String, ActiveLogin) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
createReadTransaction() - Method in class com.swiftmq.impl.jms.standard.v750.Consumer
 
createReadTransaction() - Method in class com.swiftmq.impl.mqtt.pubsub.Consumer
 
createReadTransaction(boolean) - Method in class com.swiftmq.impl.store.standard.PersistentStoreImpl
 
createReceiver(int) - Method in class com.swiftmq.impl.mqtt.pubsub.Consumer
 
createReceiver(int) - Method in class com.swiftmq.impl.mqtt.pubsub.DurableConsumer
 
createRegularQueueFactory() - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
createReplyInstance() - Method in class com.swiftmq.impl.jms.standard.v750.CollectRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.jms.standard.v750.DeliveryItem
 
createReplyInstance() - Method in class com.swiftmq.impl.jms.standard.v750.RegisterMessageProcessor
 
createReplyInstance() - Method in class com.swiftmq.impl.jms.standard.v750.RunMessageProcessor
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.BulkRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.CloseStageQueueRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.DeliveryRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.KeepAliveRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.ProtocolReplyRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.ProtocolRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.SendRouteRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.StartStageRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.AdjustRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.AuthReplyRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.AuthRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.CommitReplyRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.CommitRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ConnectReplyRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ConnectRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RecoveryReplyRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RecoveryRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RollbackReplyRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RollbackRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RouteRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.StartDeliveryRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ThrottleRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.TransactionRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.AdjustRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.AuthReplyRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.AuthRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.CommitReplyRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.CommitRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectReplyRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.NonXACommitRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.NonXATransactionRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RecoveryReplyRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RecoveryRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RollbackReplyRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RollbackRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RouteRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.StartDeliveryRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ThrottleRequest
 
createReplyInstance() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.TransactionRequest
 
createResourceLimitGroup(String) - Method in class com.swiftmq.impl.auth.standard.AuthenticationSwiftletImpl
 
createRoute(String, String, int) - Method in class com.swiftmq.impl.routing.single.route.RouteConverter
 
createSaslServer(String, String, String, Map, CallbackHandler) - Method in class com.swiftmq.impl.amqp.sasl.provider.SaslServerFactoryImpl
 
createSchedule(SwiftletContext, Entity) - Static method in class com.swiftmq.impl.scheduler.standard.ScheduleFactory
 
createSchedule(SwiftletContext, String, String, String, String, String, String, String, String, boolean) - Static method in class com.swiftmq.impl.scheduler.standard.ScheduleFactory
 
createSchedule(SwiftletContext, MessageImpl, String, String, String, String, String) - Static method in class com.swiftmq.impl.scheduler.standard.ScheduleFactory
 
createSender() - Method in class com.swiftmq.impl.streams.comp.io.Output
 
createSender() - Method in class com.swiftmq.impl.streams.comp.io.QueueOutput
 
createSender() - Method in class com.swiftmq.impl.streams.comp.io.TopicOutput
 
createServerContext() - Static method in class com.swiftmq.impl.net.netty.SSLContextFactory
 
createSession(CreateSessionRequest, int, Entity) - Method in class com.swiftmq.impl.jms.standard.v750.JMSConnection
 
createStableStore(StoreContext, String, int) - Method in class com.swiftmq.impl.store.standard.StoreSwiftletImpl
 
createSwapFile(String, String, long) - Method in interface com.swiftmq.impl.store.standard.swap.SwapFileFactory
 
createSwapFile(String, String, long) - Method in class com.swiftmq.impl.store.standard.swap.SwapFileFactoryImpl
 
createSwapFileFactory() - Method in class com.swiftmq.impl.store.standard.StoreSwiftletImpl
 
createSwiftletContext(RoutingSwiftletImpl, Entity) - Method in class com.swiftmq.impl.routing.single.RoutingSwiftletImpl
 
createSwiftletContext(RoutingSwiftletImpl, Entity) - Method in class com.swiftmq.impl.routing.unlimited.URoutingSwiftletImpl
 
createSwiftletContext(Configuration) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
createSystemQueueFactory() - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
createTCPConnector(ConnectorMetaData) - Method in class com.swiftmq.impl.net.netty.NetworkSwiftletImpl
 
createTCPListener(ListenerMetaData) - Method in class com.swiftmq.impl.net.netty.NetworkSwiftletImpl
 
createTemporaryQueue() - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
createTempQueueFactory() - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
createTopic(String) - Method in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
createTopicInfo(String, String, String[], int) - Static method in class com.swiftmq.impl.topic.standard.announce.TopicInfoFactory
 
createTopicInfo(String, String, String, String[], boolean) - Static method in class com.swiftmq.impl.topic.standard.announce.TopicInfoFactory
 
createTopicInfo(String, String, String, String[], int) - Static method in class com.swiftmq.impl.topic.standard.announce.TopicInfoFactory
 
createTraceSpace(String) - Method in class com.swiftmq.impl.trace.standard.TraceSwiftletImpl
Abstract factory method to create a trace space.
createTransaction() - Method in class com.swiftmq.impl.jms.standard.v750.Consumer
 
createTransaction() - Method in class com.swiftmq.impl.jms.standard.v750.Producer
 
createTransaction() - Method in interface com.swiftmq.impl.jms.standard.v750.TransactionFactory
 
createTransaction() - Method in class com.swiftmq.impl.mqtt.pubsub.Consumer
 
createTransaction() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
createTxId() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.transaction.TransactionRegistry
 
createTxId() - Method in class com.swiftmq.impl.store.standard.transaction.TransactionManager
 
createTxId(boolean) - Method in class com.swiftmq.impl.store.standard.transaction.TransactionManager
 
createTxLogFile(String, String) - Method in class com.swiftmq.impl.store.standard.StoreSwiftletImpl
 
createView(Selector) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
createWriteTransaction() - Method in class com.swiftmq.impl.store.standard.PersistentStoreImpl
 
createXAContext(XidImpl) - Method in class com.swiftmq.impl.xa.standard.XAResourceManagerSwiftletImpl
 
ctx - Variable in class com.swiftmq.impl.jms.standard.JMSSwiftlet
 
ctx - Variable in class com.swiftmq.impl.jms.standard.v750.Consumer
 
ctx - Variable in class com.swiftmq.impl.jms.standard.v750.Producer
 
ctx - Variable in class com.swiftmq.impl.jms.standard.v750.Session
 
ctx - Variable in class com.swiftmq.impl.routing.single.connection.stage.Stage
 
ctx - Variable in class com.swiftmq.impl.routing.single.RoutingSwiftletImpl
 
ctx - Variable in class com.swiftmq.impl.store.standard.cache.StableStore
 
ctx - Variable in class com.swiftmq.impl.streams.StreamContext
 
current() - Method in interface com.swiftmq.impl.streams.comp.io.Input
Returns the current Message of this Input.
current() - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
 
current() - Method in class com.swiftmq.impl.streams.comp.io.QueueInput
 
current() - Method in class com.swiftmq.impl.streams.comp.io.QueueWireTapInput
 
current() - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
 
current() - Method in class com.swiftmq.impl.streams.Stream
Returns the currently processed Message.
current(Message) - Method in interface com.swiftmq.impl.streams.comp.io.Input
Sets the current Message on this Input.
current(Message) - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
 
current(Message) - Method in class com.swiftmq.impl.streams.comp.io.QueueInput
 
current(Message) - Method in class com.swiftmq.impl.streams.comp.io.QueueWireTapInput
 
current(Message) - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
 
current(Message) - Method in class com.swiftmq.impl.streams.Stream
Sets/overwrites the currently processed Message.
currentTime() - Method in class com.swiftmq.impl.streams.TimeSupport
Returns the current System time

D

data - Variable in class com.swiftmq.impl.store.standard.cache.Page
 
dataAvailable(Connection, InputStream) - Method in class com.swiftmq.impl.amqp.VersionedConnection
 
dataAvailable(Connection, InputStream) - Method in class com.swiftmq.impl.jms.standard.v750.InboundReader
 
dataAvailable(Connection, InputStream) - Method in class com.swiftmq.impl.jms.standard.VersionSelector
 
dataAvailable(Connection, InputStream) - Method in class com.swiftmq.impl.mqtt.v311.PacketDecoder
 
dataAvailable(Connection, InputStream) - Method in class com.swiftmq.impl.routing.single.connection.InboundReader
 
dataAvailable(LengthCaptureDataInput) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandler
 
dataAvailable(LengthCaptureDataInput) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.AMQPHandler
 
dataAvailable(LengthCaptureDataInput) - Method in class com.swiftmq.impl.amqp.sasl.v01_00_00.SASLHandler
 
dataAvailable(LengthCaptureDataInput) - Method in class com.swiftmq.impl.amqp.VersionedConnection
 
day() - Method in class com.swiftmq.impl.streams.TimeSupport
Returns the day of the current time.
day(long, int) - Method in class com.swiftmq.impl.streams.TimeSupport
Returns the day from the time+offset.
dayDisplayName() - Method in class com.swiftmq.impl.streams.TimeSupport
Returns the display name of the day (e.g.
dayDisplayName(long, int) - Method in class com.swiftmq.impl.streams.TimeSupport
Returns the display name of the day (e.g.
days(int) - Method in class com.swiftmq.impl.streams.comp.memory.GroupInactivityTimeout
Adds n days to the timeout.
days(int) - Method in class com.swiftmq.impl.streams.comp.memory.InactivityTimeout
Adds n days to the timeout.
days(int) - Method in class com.swiftmq.impl.streams.comp.memory.limit.TimeLimit
Adds n days to the limit.
days(int) - Method in class com.swiftmq.impl.streams.comp.memory.limit.TimeUnitChangeLimit
Sets a days time unit limit
days(int) - Method in class com.swiftmq.impl.streams.comp.timer.IntervalTimer
Adds n days to the interval.
dbEntity - Variable in class com.swiftmq.impl.store.standard.StoreContext
 
declare(String, ExchangeFactory) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.ExchangeRegistry
 
decNumberConnections() - Method in class com.swiftmq.impl.auth.standard.User
 
decode(ByteBuf, List<MqttMessage>) - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttDecoder
 
DecoderException - Exception in com.swiftmq.impl.mqtt.v311.netty.handler.codec
An CodecException which is thrown by a decoder.
DecoderException() - Constructor for exception com.swiftmq.impl.mqtt.v311.netty.handler.codec.DecoderException
Creates a new instance.
DecoderException(String) - Constructor for exception com.swiftmq.impl.mqtt.v311.netty.handler.codec.DecoderException
Creates a new instance.
DecoderException(String, Throwable) - Constructor for exception com.swiftmq.impl.mqtt.v311.netty.handler.codec.DecoderException
Creates a new instance.
DecoderException(Throwable) - Constructor for exception com.swiftmq.impl.mqtt.v311.netty.handler.codec.DecoderException
Creates a new instance.
decoderResult() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessage
 
DecoderResult - Class in com.swiftmq.impl.mqtt.v311.netty.handler.codec
 
DecoderResult(Throwable) - Constructor for class com.swiftmq.impl.mqtt.v311.netty.handler.codec.DecoderResult
 
decreaseActiveTransactions() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
decreaseActiveTransactions() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
decreaseActiveTransactions() - Method in interface com.swiftmq.impl.amqp.amqp.v01_00_00.transaction.ResourceProvider
 
decRefCountAndMarkActive() - Method in class com.swiftmq.impl.store.standard.index.MessagePageReference
 
deepCopy(Object) - Static method in class com.swiftmq.impl.scheduler.standard.Util
 
DefaultScheduler - Class in com.swiftmq.impl.routing.single.schedule
 
DefaultScheduler(SwiftletContext, String, String) - Constructor for class com.swiftmq.impl.routing.single.schedule.DefaultScheduler
 
DefaultScheduler.ConnectionEntry - Class in com.swiftmq.impl.routing.single.schedule
 
deferredClose() - Method in class com.swiftmq.impl.streams.comp.memory.HeapMemory
 
deferredClose() - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Internal use.
deferredClose() - Method in class com.swiftmq.impl.streams.comp.memory.MemoryGroup
Internal Use.
deferredClose() - Method in class com.swiftmq.impl.streams.comp.memory.QueueMemory
 
deferredClose() - Method in class com.swiftmq.impl.streams.comp.memory.TempQueueMemory
 
deferredClose() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
DELAY - Static variable in class com.swiftmq.impl.scheduler.standard.ScheduleFactory
 
delete() - Method in class com.swiftmq.impl.store.standard.PersistentStoreImpl
 
delete() - Method in class com.swiftmq.impl.streams.comp.io.TempQueue
Deletes the temporary queue and removes it from JNDI, if registered
delete(Object) - Method in class com.swiftmq.impl.store.standard.NonPersistentStoreImpl
 
delete(String, boolean) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.ExchangeRegistry
 
DELETE - Static variable in class com.swiftmq.impl.store.standard.log.LogAction
 
deleteContent() - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredQueue
 
deleteContent() - Method in class com.swiftmq.impl.queue.standard.composite.CompositeQueue
 
deleteContent() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
deleteDurable(String, ActiveLogin) - Method in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
DeleteDurableJob - Class in com.swiftmq.impl.topic.standard.jobs
 
DeleteDurableJob(TopicManagerImpl, TraceSpace, EntityList) - Constructor for class com.swiftmq.impl.topic.standard.jobs.DeleteDurableJob
 
DeleteDurableJobFactory - Class in com.swiftmq.impl.topic.standard.jobs
 
DeleteDurableJobFactory(TopicManagerImpl, TraceSpace, EntityList) - Constructor for class com.swiftmq.impl.topic.standard.jobs.DeleteDurableJobFactory
 
deleteDurableStoreEntry(String, String) - Method in class com.swiftmq.impl.store.standard.DurableSubscriberStoreImpl
 
deleteGroupEntry(MessageGroupEntry) - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
DeleteLogAction - Class in com.swiftmq.impl.store.standard.log
 
DeleteLogAction(int, byte[]) - Constructor for class com.swiftmq.impl.store.standard.log.DeleteLogAction
 
deleteQueue(String, boolean) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
deleteQueueIndex(String, QueueIndex) - Method in class com.swiftmq.impl.store.standard.index.RootIndex
 
deleteStore() - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
deleteSwapFilesOnClose() - Method in class com.swiftmq.impl.store.standard.NonPersistentStoreImpl
 
deleteSwaps() - Method in class com.swiftmq.impl.store.standard.StoreSwiftletImpl
 
deleteTemporaryQueue(String) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
deleteTopic(String) - Method in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
deleteView(int) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
delivered(DeliveryRequest) - Method in class com.swiftmq.impl.routing.single.schedule.Scheduler
 
delivered(DeliveryRequest) - Method in interface com.swiftmq.impl.routing.single.smqpr.DeliveryCallback
 
deliveredList - Variable in class com.swiftmq.impl.jms.standard.v750.NontransactedSession
 
Delivery - Class in com.swiftmq.impl.amqp.amqp.v00_09_01
 
Delivery - Class in com.swiftmq.impl.amqp.amqp.v01_00_00
 
Delivery(SourceLink, MessageImpl, MessageIndex) - Constructor for class com.swiftmq.impl.amqp.amqp.v01_00_00.Delivery
 
Delivery(ContentHeaderProperties, byte[]) - Constructor for class com.swiftmq.impl.amqp.amqp.v00_09_01.Delivery
 
DELIVERY_REQ - Static variable in class com.swiftmq.impl.routing.single.smqpr.SMQRFactory
 
DeliveryCallback - Interface in com.swiftmq.impl.routing.single.smqpr
 
DeliveryItem - Class in com.swiftmq.impl.jms.standard.v750
 
DeliveryItem() - Constructor for class com.swiftmq.impl.jms.standard.v750.DeliveryItem
 
DeliveryRequest - Class in com.swiftmq.impl.routing.single.smqpr
 
DeliveryRequest() - Constructor for class com.swiftmq.impl.routing.single.smqpr.DeliveryRequest
 
DeliveryRequest(String, QueueReceiver, QueuePullTransaction, MessageEntry[], int, DeliveryCallback) - Constructor for class com.swiftmq.impl.routing.single.smqpr.DeliveryRequest
 
DeploySpaceImpl - Class in com.swiftmq.impl.deploy.standard
 
DeploySpaceImpl(SwiftletContext, Entity) - Constructor for class com.swiftmq.impl.deploy.standard.DeploySpaceImpl
 
deploySwiftlet - Variable in class com.swiftmq.impl.deploy.standard.SwiftletContext
 
DeploySwiftletImpl - Class in com.swiftmq.impl.deploy.standard
 
DeploySwiftletImpl() - Constructor for class com.swiftmq.impl.deploy.standard.DeploySwiftletImpl
 
deregister() - Method in class com.swiftmq.impl.streams.processor.ManagementProcessor
 
deregister() - Method in class com.swiftmq.impl.streams.processor.QueueMessageProcessor
 
deregisterGroup(String) - Method in class com.swiftmq.impl.threadpool.standard.group.GroupRegistry
 
deregisterJNDIObject(String) - Method in class com.swiftmq.impl.jndi.standard.JNDISwiftletImpl
 
deregisterJNDIObjects(Comparable) - Method in class com.swiftmq.impl.jndi.standard.JNDISwiftletImpl
 
deregisterJNDIQueueObject(String) - Method in class com.swiftmq.impl.jndi.standard.JNDISwiftletImpl
 
descendingSeries(String) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Returns true if all values of a Property are less than the previous value.
destination() - Method in class com.swiftmq.impl.streams.comp.io.TempQueue
Returns the javax.jms.Destination object to set as a replyTo
destination() - Method in class com.swiftmq.impl.streams.comp.message.Message
Returns the Name of the JMSDestination.
destinationActivated(RoutingEvent) - Method in class com.swiftmq.impl.mgmt.standard.DispatchQueue
 
destinationActivated(RoutingEvent) - Method in class com.swiftmq.impl.topic.standard.announce.TopicAnnounceSender
 
destinationAdded(Route) - Method in class com.swiftmq.impl.topic.standard.announce.TopicAnnounceSender
 
destinationAdded(RoutingEvent) - Method in class com.swiftmq.impl.mgmt.standard.DispatchQueue
 
destinationAdded(RoutingEvent) - Method in class com.swiftmq.impl.topic.standard.announce.TopicAnnounceSender
 
destinationDeactivated(RoutingEvent) - Method in class com.swiftmq.impl.mgmt.standard.DispatchQueue
 
destinationDeactivated(RoutingEvent) - Method in class com.swiftmq.impl.topic.standard.announce.TopicAnnounceSender
 
DestinationFactory - Interface in com.swiftmq.impl.amqp.amqp.v00_09_01.transformer
 
DestinationFactory - Interface in com.swiftmq.impl.amqp.amqp.v01_00_00.transformer
 
DestinationInput - Interface in com.swiftmq.impl.streams.comp.io
Intermediate interface to separate JMS destination inputs.
destinationName() - Method in interface com.swiftmq.impl.streams.comp.io.DestinationInput
Returns the destinationName
destinationName() - Method in class com.swiftmq.impl.streams.comp.io.QueueInput
 
destinationName() - Method in class com.swiftmq.impl.streams.comp.io.QueueWireTapInput
 
destinationName() - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
 
destinationName(String) - Method in interface com.swiftmq.impl.streams.comp.io.DestinationInput
Sets the destinationName if different from the name used in stream.create().input(name)
destinationName(String) - Method in class com.swiftmq.impl.streams.comp.io.QueueInput
 
destinationName(String) - Method in class com.swiftmq.impl.streams.comp.io.QueueWireTapInput
 
destinationName(String) - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
 
destinationRemoved(RoutingEvent) - Method in class com.swiftmq.impl.mgmt.standard.DispatchQueue
 
destinationRemoved(RoutingEvent) - Method in class com.swiftmq.impl.topic.standard.announce.TopicAnnounceSender
 
destinationRouter - Variable in class com.swiftmq.impl.routing.single.smqpr.DeliveryRequest
 
destroy() - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
destroy(boolean) - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
destroy(ActiveLogin, boolean) - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
DIRECT - Static variable in interface com.swiftmq.impl.amqp.amqp.v00_09_01.Exchange
 
dirty - Variable in class com.swiftmq.impl.store.standard.cache.Page
 
disassociateSession(String, MQTTSession) - Method in class com.swiftmq.impl.mqtt.session.SessionRegistry
 
discharge(TxnIdIF, boolean) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.transaction.TransactionRegistry
 
disconnect() - Method in class com.swiftmq.impl.jndi.standard.JNDIReplication
 
disconnect() - Method in class com.swiftmq.impl.streams.comp.io.MailServer
Disconnects from the mail server.
Disconnect - Class in com.swiftmq.impl.mgmt.standard.po
 
Disconnect(String) - Constructor for class com.swiftmq.impl.mgmt.standard.po.Disconnect
 
DISCONNECT - Enum constant in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageType
 
dispatch(POObject) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandler
 
dispatch(POObject) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.ChannelHandler
 
dispatch(POObject) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.AMQPHandler
 
dispatch(POObject) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler
 
dispatch(POObject) - Method in class com.swiftmq.impl.amqp.sasl.v01_00_00.SASLHandler
 
dispatch(POObject) - Method in class com.swiftmq.impl.mqtt.connection.MQTTConnection
 
dispatch(POObject) - Method in class com.swiftmq.impl.streams.processor.StreamProcessor
 
dispatchClientRequest(String, String, byte[]) - Method in class com.swiftmq.impl.mgmt.standard.DispatchQueue
 
dispatcher - Variable in class com.swiftmq.impl.timer.standard.SwiftletContext
 
Dispatcher - Interface in com.swiftmq.impl.mgmt.standard
 
DispatcherImpl - Class in com.swiftmq.impl.mgmt.standard.v750
 
DispatcherImpl(SwiftletContext, String, String) - Constructor for class com.swiftmq.impl.mgmt.standard.v750.DispatcherImpl
 
dispatchId - Variable in class com.swiftmq.impl.jms.standard.v750.Session
 
DispatchPolicy - Interface in com.swiftmq.impl.queue.standard.cluster
 
DispatchPolicyListener - Interface in com.swiftmq.impl.queue.standard.cluster
 
dispatchPolicyRegistry - Variable in class com.swiftmq.impl.queue.standard.SwiftletContext
 
DispatchPolicyRegistry - Class in com.swiftmq.impl.queue.standard.cluster
 
DispatchPolicyRegistry(SwiftletContext) - Constructor for class com.swiftmq.impl.queue.standard.cluster.DispatchPolicyRegistry
 
dispatchQueue - Variable in class com.swiftmq.impl.mgmt.standard.SwiftletContext
 
DispatchQueue - Class in com.swiftmq.impl.mgmt.standard
 
DispatchQueue(SwiftletContext) - Constructor for class com.swiftmq.impl.mgmt.standard.DispatchQueue
 
dispatchQueueRemoved(String) - Method in interface com.swiftmq.impl.queue.standard.cluster.DispatchPolicyListener
 
dispatchQueueRemoved(String) - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
displayName(String) - Method in class com.swiftmq.impl.streams.comp.management.CLI
Returns the display name of a Property.
dispose() - Method in class com.swiftmq.impl.amqp.sasl.provider.AnonServer
 
dispose() - Method in class com.swiftmq.impl.amqp.sasl.provider.PlainServer
 
DLQ - Static variable in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
doConnect(Connection) - Method in class com.swiftmq.impl.jms.standard.JMSSwiftlet
 
doDisconnect() - Method in interface com.swiftmq.impl.mgmt.standard.Dispatcher
 
doDisconnect() - Method in class com.swiftmq.impl.mgmt.standard.v750.DispatcherImpl
 
doDisconnect(Connection) - Method in class com.swiftmq.impl.jms.standard.JMSSwiftlet
 
doEncode(MqttMessage) - Static method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttEncoder
 
doExpire() - Method in interface com.swiftmq.impl.mgmt.standard.Dispatcher
 
doExpire() - Method in class com.swiftmq.impl.mgmt.standard.v750.DispatcherImpl
 
domainName() - Method in class com.swiftmq.impl.streams.Stream
Returns the Domain Name of this Stream.
driver(String) - Method in class com.swiftmq.impl.streams.comp.jdbc.JDBCLookup
Sets the JDBC driver class name.
dropLateArrivals(boolean) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Specifies whether late arrivals should be dropped (default is false).
dump() - Method in class com.swiftmq.impl.store.standard.index.ReferenceMap
 
dumpables - Variable in class com.swiftmq.impl.routing.single.smqpr.BulkRequest
 
duplicate() - Method in class com.swiftmq.impl.mqtt.v311.netty.buffer.ByteBuf
 
duplicateBacklog - Variable in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
duplicateDetectionBacklogSize - Variable in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
duplicateDetectionEnabled - Variable in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
durable() - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
Marks this TopicInput as durable.
DURABLE_DELIMITER - Static variable in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
DURABLE_TYPE - Static variable in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
DurableConsumer - Class in com.swiftmq.impl.mqtt.pubsub
 
DurableConsumer(SwiftletContext, MQTTSession, String, int) - Constructor for class com.swiftmq.impl.mqtt.pubsub.DurableConsumer
 
durableEntity - Variable in class com.swiftmq.impl.store.standard.StoreContext
 
durableName(String) - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
Sets the durable name for a durable subscriber.
durableStore - Variable in class com.swiftmq.impl.store.standard.StoreContext
 
DurableSubscriberStoreImpl - Class in com.swiftmq.impl.store.standard
 
DurableSubscriberStoreImpl(StoreContext, String) - Constructor for class com.swiftmq.impl.store.standard.DurableSubscriberStoreImpl
 
DurableSubscription - Class in com.swiftmq.impl.topic.standard
 
DurableSubscription(DurableStoreEntry) - Constructor for class com.swiftmq.impl.topic.standard.DurableSubscription
 
DurableSubscription(String, String, String, Selector, boolean) - Constructor for class com.swiftmq.impl.topic.standard.DurableSubscription
 

E

email() - Method in class com.swiftmq.impl.streams.comp.io.MailServer
Returns a new Email facade to send a mail.
Email - Class in com.swiftmq.impl.streams.comp.io
Facade to send an eMail.
empty - Variable in class com.swiftmq.impl.store.standard.cache.Page
 
EMPTY_BYTES - Static variable in class com.swiftmq.impl.mqtt.v311.netty.util.internal.EmptyArrays
 
EmptyArrays - Class in com.swiftmq.impl.mqtt.v311.netty.util.internal
 
emptyData - Variable in class com.swiftmq.impl.store.standard.cache.StableStore
 
encode(MqttMessage, List<Object>) - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttEncoder
 
endsWith(String) - Method in class com.swiftmq.impl.streams.comp.message.PropertySet
Returns a new PropertySet that contains all Properties which name ends with the suffix.
EndWithErrorException - Exception in com.swiftmq.impl.amqp.amqp.v01_00_00
 
EndWithErrorException(ErrorConditionIF, AMQPString) - Constructor for exception com.swiftmq.impl.amqp.amqp.v01_00_00.EndWithErrorException
 
EndWithErrorExceptionVisitor - Interface in com.swiftmq.impl.amqp.amqp.v01_00_00
 
EndWithErrorExceptionVisitorAdapter - Class in com.swiftmq.impl.amqp.amqp.v01_00_00
 
EndWithErrorExceptionVisitorAdapter() - Constructor for class com.swiftmq.impl.amqp.amqp.v01_00_00.EndWithErrorExceptionVisitorAdapter
 
enqueue(Object) - Method in class com.swiftmq.impl.amqp.OutboundQueue
 
enqueue(Object) - Method in class com.swiftmq.impl.routing.single.connection.stage.StageQueue
 
enqueue(Object) - Method in class com.swiftmq.impl.routing.single.connection.v942.ThrottleQueue
 
enqueue(POObject) - Method in class com.swiftmq.impl.routing.single.manager.ConnectionManager
 
enqueue(POObject) - Method in class com.swiftmq.impl.scheduler.standard.Scheduler
 
enqueue(POObject) - Method in class com.swiftmq.impl.store.standard.processor.backup.BackupProcessor
 
enqueue(POObject) - Method in class com.swiftmq.impl.store.standard.processor.scan.ScanProcessor
 
enqueue(POObject) - Method in class com.swiftmq.impl.store.standard.processor.shrink.ShrinkProcessor
 
enqueueClose(POCloseObject) - Method in class com.swiftmq.impl.routing.single.schedule.Scheduler
 
enqueueRequest(Request) - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
ensure(int) - Method in class com.swiftmq.impl.store.standard.cache.CacheManager
 
ensure(int) - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
ensureBuffer(int) - Method in class com.swiftmq.impl.mqtt.v311.PacketDecoder
 
ensurePage(int) - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
ensureTransaction(TransactionId) - Method in class com.swiftmq.impl.queue.standard.queue.ActiveTransactionRegistry
 
entity - Variable in class com.swiftmq.impl.streams.StreamContext
 
entityAdded(Entity, Entity) - Method in class com.swiftmq.impl.mgmt.standard.DispatchQueue
 
entityAdded(Entity, Entity) - Method in class com.swiftmq.impl.mgmt.standard.jmx.EntityMBean
 
entityAdded(Entity, Entity) - Method in class com.swiftmq.impl.streams.processor.ManagementProcessor
 
entityAdded(Entity, Entity) - Method in class com.swiftmq.impl.topic.standard.announce.TopicAnnounceSender
 
entityAdded(Entity, Entity) - Method in class com.swiftmq.impl.xa.standard.HeuristicHandler
 
EntityAdded - Class in com.swiftmq.impl.mgmt.standard.po
 
EntityAdded(String[], String) - Constructor for class com.swiftmq.impl.mgmt.standard.po.EntityAdded
 
EntityMBean - Class in com.swiftmq.impl.mgmt.standard.jmx
 
EntityMBean(SwiftletContext, Entity) - Constructor for class com.swiftmq.impl.mgmt.standard.jmx.EntityMBean
 
entityNames(String) - Method in class com.swiftmq.impl.streams.comp.management.CLI
Returns a String array with the names of all entities.
entityRemoved(Entity, Entity) - Method in class com.swiftmq.impl.mgmt.standard.DispatchQueue
 
entityRemoved(Entity, Entity) - Method in class com.swiftmq.impl.mgmt.standard.jmx.EntityMBean
 
entityRemoved(Entity, Entity) - Method in class com.swiftmq.impl.streams.processor.ManagementProcessor
 
entityRemoved(Entity, Entity) - Method in class com.swiftmq.impl.topic.standard.announce.TopicAnnounceSender
 
entityRemoved(Entity, Entity) - Method in class com.swiftmq.impl.xa.standard.HeuristicHandler
 
EntityRemoved - Class in com.swiftmq.impl.mgmt.standard.po
 
EntityRemoved(String[], String) - Constructor for class com.swiftmq.impl.mgmt.standard.po.EntityRemoved
 
entries - Variable in class com.swiftmq.impl.routing.single.smqpr.DeliveryRequest
 
Entry(String, long, Message) - Constructor for class com.swiftmq.impl.streams.comp.memory.Memory.Entry
 
equals(Object) - Method in class com.swiftmq.impl.mqtt.v311.netty.util.AbstractConstant
 
equals(Object) - Method in error com.swiftmq.impl.mqtt.v311.netty.util.Signal
 
equals(Object) - Method in record class com.swiftmq.impl.queue.standard.queue.PropertyWatchManager.PropertyWatchEntry
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class com.swiftmq.impl.store.standard.index.IndexEntry
 
equals(Object) - Method in class com.swiftmq.impl.streams.AsyncProxy
 
equals(Object) - Method in class com.swiftmq.impl.topic.standard.DurableSubscription
 
equals(Object) - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
error(String) - Method in class com.swiftmq.impl.streams.comp.log.Log
Write a error message to the log file.
evaluateResponse(byte[]) - Method in class com.swiftmq.impl.amqp.sasl.provider.AnonServer
 
evaluateResponse(byte[]) - Method in class com.swiftmq.impl.amqp.sasl.provider.PlainServer
 
EventLoopImpl - Class in com.swiftmq.impl.threadpool.standard.group
 
EventLoopImpl(SwiftletContext, String, boolean, EventProcessor, ThreadRunner) - Constructor for class com.swiftmq.impl.threadpool.standard.group.EventLoopImpl
 
EventObject - Class in com.swiftmq.impl.mgmt.standard.po
 
EventObject() - Constructor for class com.swiftmq.impl.mgmt.standard.po.EventObject
 
EventObject(Semaphore) - Constructor for class com.swiftmq.impl.mgmt.standard.po.EventObject
 
EventObjectVisitor - Interface in com.swiftmq.impl.mgmt.standard.po
 
EventVisitor - Interface in com.swiftmq.impl.mgmt.standard.po
 
EventVisitor - Interface in com.swiftmq.impl.scheduler.standard.po
 
EventVisitor - Interface in com.swiftmq.impl.store.standard.processor.backup.po
 
EventVisitor - Interface in com.swiftmq.impl.store.standard.processor.scan.po
 
EventVisitor - Interface in com.swiftmq.impl.store.standard.processor.shrink.po
 
EXACTLY_ONCE - Enum constant in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttQoS
 
ExceptionCallback - Interface in com.swiftmq.impl.streams
Callback that can be registered on the Stream (onException).
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class com.swiftmq.impl.net.netty.scheduler.NettyInboundConnectionHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class com.swiftmq.impl.net.netty.scheduler.NettyOutboundConnectionHandler
 
exceptionOff() - Method in class com.swiftmq.impl.streams.comp.management.CLI
Tells CLI to don't throw exceptions when they occur on execute().
exceptionOn() - Method in class com.swiftmq.impl.streams.comp.management.CLI
Tells CLI to throw exceptions when they occur on execute().
Exchange - Interface in com.swiftmq.impl.amqp.amqp.v00_09_01
 
ExchangeFactory - Interface in com.swiftmq.impl.amqp.amqp.v00_09_01
 
exchangeRegistry - Variable in class com.swiftmq.impl.amqp.SwiftletContext
 
ExchangeRegistry - Class in com.swiftmq.impl.amqp.amqp.v00_09_01
 
ExchangeRegistry(SwiftletContext) - Constructor for class com.swiftmq.impl.amqp.amqp.v00_09_01.ExchangeRegistry
 
execute(Input) - Method in interface com.swiftmq.impl.streams.comp.io.InputCallback
Single callback method executed as the function call as function (input){...}
execute(Memory) - Method in interface com.swiftmq.impl.streams.comp.memory.ForEachMemoryCallback
Single method to be executed for each Memory of a MemoryGroup
execute(Memory) - Method in interface com.swiftmq.impl.streams.comp.memory.RetirementCallback
Single method which is called during Memory.checkLimit().
execute(Message) - Method in interface com.swiftmq.impl.streams.comp.memory.ForEachMessageCallback
Single method to be executed for each Message of a Memory
execute(Property) - Method in interface com.swiftmq.impl.streams.comp.message.ForEachPropertyCallback
Single method to be executed for each Property of a PropertySet
execute(Timer) - Method in interface com.swiftmq.impl.streams.comp.timer.TimerCallback
Single callback method executed as the function call as function (timer){...}
execute(Object) - Method in interface com.swiftmq.impl.streams.FunctionCallback
 
execute(Runnable) - Method in class com.swiftmq.impl.net.netty.scheduler.TaskExecutor
 
execute(Runnable) - Method in class com.swiftmq.impl.threadpool.standard.group.pool.PlatformThreadRunner
 
execute(Runnable) - Method in interface com.swiftmq.impl.threadpool.standard.group.pool.ThreadRunner
 
execute(Runnable) - Method in class com.swiftmq.impl.threadpool.standard.group.pool.VirtualThreadRunner
 
execute(String) - Method in class com.swiftmq.impl.mgmt.standard.CLIExecutorImpl
 
execute(String) - Method in class com.swiftmq.impl.streams.comp.management.CLI
Executes a CLI command on the local router's management tree.
execute(String[], Entity, String[]) - Method in class com.swiftmq.impl.queue.standard.command.Activate
 
execute(String[], Entity, String[]) - Method in class com.swiftmq.impl.queue.standard.command.Copier
 
execute(String[], Entity, String[]) - Method in class com.swiftmq.impl.queue.standard.command.Exporter
 
execute(String[], Entity, String[]) - Method in class com.swiftmq.impl.queue.standard.command.Importer
 
execute(String[], Entity, String[]) - Method in class com.swiftmq.impl.queue.standard.command.Remover
 
execute(String[], Entity, String[]) - Method in class com.swiftmq.impl.queue.standard.command.Resetter
 
execute(String[], Entity, String[]) - Method in class com.swiftmq.impl.queue.standard.command.Viewer
 
execute(String, String) - Method in interface com.swiftmq.impl.streams.ExceptionCallback
Single method executed as a function call as function(exception, lastStackTrace){...}
executeCallback() - Method in interface com.swiftmq.impl.streams.comp.io.Input
Internal use.
executeCallback() - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
 
executeCallback() - Method in class com.swiftmq.impl.streams.comp.io.QueueInput
 
executeCallback() - Method in class com.swiftmq.impl.streams.comp.io.QueueWireTapInput
 
executeCallback() - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
 
executeCallback() - Method in class com.swiftmq.impl.streams.comp.timer.AtTimer
 
executeCallback() - Method in class com.swiftmq.impl.streams.comp.timer.IntervalTimer
 
executeCallback() - Method in class com.swiftmq.impl.streams.comp.timer.NextTimer
 
executeCallback() - Method in interface com.swiftmq.impl.streams.comp.timer.Timer
Internal use.
executeCallback(FunctionCallback, Object) - Method in class com.swiftmq.impl.streams.Stream
Executes a function callback in the Stream's event queue.
executeOnExceptionCallback() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
executeOnMessageCallback() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
executeOnStartCallback() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
executeOnStopCallback() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
executeWithResult(String) - Method in class com.swiftmq.impl.mgmt.standard.CLIExecutorImpl
 
executeWithResult(String) - Method in class com.swiftmq.impl.streams.comp.management.CLI
Executes a CLI command on the local router's management tree and returns the result as an Json Array.
exists() - Method in class com.swiftmq.impl.streams.comp.message.Property
Returns whether this Property exists in the Message
exists(String) - Method in class com.swiftmq.impl.mqtt.v311.netty.util.ConstantPool
 
expect(Signal) - Method in error com.swiftmq.impl.mqtt.v311.netty.util.Signal
Check if the given Signal is the same as this instance.
expiration() - Method in class com.swiftmq.impl.streams.comp.message.Message
Returns the JMS expiration.
expiration(long) - Method in class com.swiftmq.impl.streams.comp.message.Message
Sets the JMS expiration
Exporter - Class in com.swiftmq.impl.queue.standard.command
 
Exporter(SwiftletContext) - Constructor for class com.swiftmq.impl.queue.standard.command.Exporter
 

F

FACTORY - Static variable in class com.swiftmq.impl.queue.standard.cluster.v700.MetricFactory
 
failure(Throwable) - Static method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.DecoderResult
 
FAILURE - Enum constant in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttQoS
 
FANOUT - Static variable in interface com.swiftmq.impl.amqp.amqp.v00_09_01.Exchange
 
fetchAndPin(int) - Method in class com.swiftmq.impl.store.standard.cache.CacheManager
 
fetchBrowserMessage(FetchBrowserMessageRequest) - Method in class com.swiftmq.impl.jms.standard.v750.BrowserManager
 
file - Variable in class com.swiftmq.impl.store.standard.cache.StableStore
 
fileLength - Variable in class com.swiftmq.impl.store.standard.cache.StableStore
 
filename - Variable in class com.swiftmq.impl.store.standard.cache.StableStore
 
filename - Variable in class com.swiftmq.impl.store.standard.swap.SwapFileImpl
 
FILENAME - Static variable in class com.swiftmq.impl.store.standard.cache.StableStore
 
FILENAME - Static variable in interface com.swiftmq.impl.store.standard.log.LogManager
 
filePointer - Variable in class com.swiftmq.impl.store.standard.swap.SwapAddress
 
filesList - Variable in class com.swiftmq.impl.store.standard.StoreContext
 
fillConnectionUsage(Entity) - Method in class com.swiftmq.impl.mqtt.pubsub.Subscription
 
fillConnectionUsage(Entity) - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
fillInStackTrace() - Method in error com.swiftmq.impl.mqtt.v311.netty.util.Signal
 
fillRegistryUsage(Entity) - Method in class com.swiftmq.impl.mqtt.pubsub.Subscription
 
fillRegistryUsage(Entity) - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
fillUsage() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
fillUsage() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
fillUsage() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
find(Comparable) - Method in class com.swiftmq.impl.store.standard.index.Index
 
finished(Job, JobException) - Method in class com.swiftmq.impl.queue.standard.jobs.MultiQueuePurgerJobFactory
 
finished(Job, JobException) - Method in class com.swiftmq.impl.queue.standard.jobs.QueueCleanupDLQJobFactory
 
finished(Job, JobException) - Method in class com.swiftmq.impl.queue.standard.jobs.QueueCleanupJobFactory
 
finished(Job, JobException) - Method in class com.swiftmq.impl.queue.standard.jobs.QueueMoverJobFactory
 
finished(Job, JobException) - Method in class com.swiftmq.impl.queue.standard.jobs.QueuePurgerJobFactory
 
finished(Job, JobException) - Method in class com.swiftmq.impl.queue.standard.jobs.QueueResetJobFactory
 
finished(Job, JobException) - Method in class com.swiftmq.impl.routing.single.jobs.RoutingConnectorJobFactory
 
finished(Job, JobException) - Method in class com.swiftmq.impl.scheduler.standard.job.MessageSenderJobFactory
 
finished(Job, JobException) - Method in class com.swiftmq.impl.store.standard.jobs.BackupJobFactory
 
finished(Job, JobException) - Method in class com.swiftmq.impl.store.standard.jobs.ScanJobFactory
 
finished(Job, JobException) - Method in class com.swiftmq.impl.store.standard.jobs.ShrinkJobFactory
 
finished(Job, JobException) - Method in class com.swiftmq.impl.streams.jobs.StreamsJobFactory
 
finished(Job, JobException) - Method in class com.swiftmq.impl.topic.standard.jobs.DeleteDurableJobFactory
 
fireEvent(boolean) - Method in class com.swiftmq.impl.mgmt.standard.MgmtSwiftletImpl
 
first() - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Returns the first Message of this Memory.
fixedHeader() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessage
 
FlowControllerImpl - Class in com.swiftmq.impl.queue.standard.queue
 
FlowControllerImpl(int, long) - Constructor for class com.swiftmq.impl.queue.standard.queue.FlowControllerImpl
 
FlowcontrolTimer - Class in com.swiftmq.impl.amqp.amqp.v01_00_00
 
FlowcontrolTimer(SessionHandler, TargetLink) - Constructor for class com.swiftmq.impl.amqp.amqp.v01_00_00.FlowcontrolTimer
 
flush() - Method in interface com.swiftmq.impl.mgmt.standard.Dispatcher
 
flush() - Method in class com.swiftmq.impl.mgmt.standard.v750.DispatcherImpl
 
flush() - Method in class com.swiftmq.impl.net.netty.CountableBufferedOutputStream
 
flush() - Method in class com.swiftmq.impl.net.netty.CountableWrappedOutputStream
 
flush() - Method in class com.swiftmq.impl.store.standard.cache.CacheManager
 
flush() - Method in class com.swiftmq.impl.store.standard.index.PageOutputStream
 
flush() - Method in class com.swiftmq.impl.streams.comp.memory.TxBookKeeper
 
flush() - Method in interface com.swiftmq.impl.streams.TransactionFlushListener
 
flush(boolean) - Method in class com.swiftmq.impl.store.standard.log.AppendLogFile
 
flush(boolean) - Method in interface com.swiftmq.impl.store.standard.log.LogFile
 
flush(boolean) - Method in class com.swiftmq.impl.store.standard.log.ReuseLogFile
 
flush(List<CheckPointFinishedListener>) - Method in class com.swiftmq.impl.store.standard.cache.CacheManager
 
flushCache() - Method in class com.swiftmq.impl.store.standard.StoreSwiftletImpl
 
flushTo(OutputStream) - Method in class com.swiftmq.impl.mqtt.v311.netty.buffer.ByteBuf
 
forAddress(Destination) - Method in class com.swiftmq.impl.streams.comp.io.OutputBuilder
Verifies the type of the address (Topic/Queue) and returns the corresponding Output.
forEach(ForEachMemoryCallback) - Method in class com.swiftmq.impl.streams.comp.memory.GroupResult
Executes the Callback for each Memory in this GroupResult
forEach(ForEachMemoryCallback) - Method in class com.swiftmq.impl.streams.comp.memory.MemoryGroup
Executes the Callback for each Memory in this MemoryGroup
forEach(ForEachMessageCallback) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Executes the Callback for each Message in this Memory
forEach(ForEachPropertyCallback) - Method in class com.swiftmq.impl.streams.comp.message.PropertySet
Invokes the callback for each Property of this PropertySet
ForEachMemoryCallback - Interface in com.swiftmq.impl.streams.comp.memory
Callback that can be registered on the forEach() method of a MemoryGroup or a GroupResult.
ForEachMessageCallback - Interface in com.swiftmq.impl.streams.comp.memory
Callback that can be registered on the forEach() method of a Memory.
ForEachPropertyCallback - Interface in com.swiftmq.impl.streams.comp.message
Callback that can be registered on the forEach() method of a PropertySet.
FOREVER - Static variable in class com.swiftmq.impl.scheduler.standard.ScheduleFactory
 
forget(XidImpl) - Method in class com.swiftmq.impl.xa.standard.XAResourceManagerSwiftletImpl
 
format(long, String) - Method in class com.swiftmq.impl.streams.TimeSupport
Formats the time according to the pattern.
forwardWireTaps(MessageImpl) - Method in class com.swiftmq.impl.queue.standard.queue.WireTapManager
 
fqn() - Method in class com.swiftmq.impl.streams.StreamController
 
fqn(String) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
free(Page) - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
freePages - Variable in class com.swiftmq.impl.store.standard.cache.StableStore
 
freeze() - Method in class com.swiftmq.impl.threadpool.standard.group.EventLoopImpl
 
freeze() - Method in class com.swiftmq.impl.threadpool.standard.ThreadpoolSwiftletImpl
 
freezeGroup() - Method in class com.swiftmq.impl.threadpool.standard.group.Group
 
freezeGroups() - Method in class com.swiftmq.impl.threadpool.standard.group.GroupRegistry
 
from(int) - Static method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
 
from(String) - Method in class com.swiftmq.impl.streams.comp.io.Email
Sets the from address
fromProtocolNameAndLevel(String, byte) - Static method in enum class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttVersion
 
fullyQualifiedName() - Method in class com.swiftmq.impl.streams.Stream
Returns the fully qualified Stream name: domain.package.name
FunctionCallback - Interface in com.swiftmq.impl.streams
 

G

get(int) - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
get(long) - Method in interface com.swiftmq.impl.store.standard.swap.SwapFile
 
get(long) - Method in class com.swiftmq.impl.store.standard.swap.SwapFileImpl
 
get(long) - Method in class com.swiftmq.impl.store.standard.xa.PreparedLog
 
get(long) - Method in class com.swiftmq.impl.store.standard.xa.PreparedLogFile
 
get(long) - Method in class com.swiftmq.impl.store.standard.xa.PreparedLogQueue
 
get(StoreId) - Method in interface com.swiftmq.impl.queue.standard.queue.Cache
 
get(StoreId) - Method in class com.swiftmq.impl.queue.standard.queue.CacheImpl
 
get(QueueIndexEntry) - Method in class com.swiftmq.impl.store.standard.index.QueueIndex
 
get(Object) - Method in class com.swiftmq.impl.store.standard.NonPersistentStoreImpl
 
get(Object) - Method in class com.swiftmq.impl.store.standard.PersistentStoreImpl
 
get(Object) - Method in class com.swiftmq.impl.streams.comp.memory.Index
Selects all Messages with a specific Property Value from the associated Memory and returns the result as new non-queue Memory.
get(String) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.ExchangeRegistry
 
get(String) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.QueueMapper
 
get(String) - Method in class com.swiftmq.impl.mqtt.retain.MemoryRetainer
 
get(String) - Method in interface com.swiftmq.impl.mqtt.retain.Retainer
 
get(String) - Method in class com.swiftmq.impl.queue.standard.cluster.DispatchPolicyRegistry
 
get(String) - Method in class com.swiftmq.impl.streams.comp.message.MapBody
Get a map value.
get(String) - Method in class com.swiftmq.impl.streams.Parameters
Returns the parameter value for this name.
get(String) - Method in class com.swiftmq.impl.streams.RepositorySupport
 
getActivationListener() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getActiveLogin() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandler
 
getActiveLogin() - Method in class com.swiftmq.impl.amqp.VersionedConnection
 
getActiveLogin() - Method in class com.swiftmq.impl.mqtt.connection.MQTTConnection
 
getActiveLogin() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
getActiveThreadCount() - Method in class com.swiftmq.impl.threadpool.standard.group.pool.PlatformThreadRunner
 
getActiveThreadCount() - Method in interface com.swiftmq.impl.threadpool.standard.group.pool.ThreadRunner
 
getActiveThreadCount() - Method in class com.swiftmq.impl.threadpool.standard.group.pool.VirtualThreadRunner
 
getActiveTransactions() - Method in class com.swiftmq.impl.store.standard.transaction.TransactionManager
 
getAddress() - Method in class com.swiftmq.impl.store.standard.xa.PrepareLogRecordImpl
 
getAfterImage() - Method in class com.swiftmq.impl.store.standard.log.UpdateLogAction
 
getAfterImage() - Method in class com.swiftmq.impl.store.standard.log.UpdatePortionLogAction
 
getAll() - Method in class com.swiftmq.impl.store.standard.xa.PreparedLog
 
getAll() - Method in class com.swiftmq.impl.store.standard.xa.PreparedLogFile
 
getAll() - Method in class com.swiftmq.impl.store.standard.xa.PreparedLogQueue
 
getAmqpMessage() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.Delivery
 
getAndResetAverageLatency() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getAttribute(String) - Method in class com.swiftmq.impl.mgmt.standard.jmx.EntityMBean
 
getAttributes(String[]) - Method in class com.swiftmq.impl.mgmt.standard.jmx.EntityMBean
 
getAuthorizationID() - Method in class com.swiftmq.impl.amqp.sasl.provider.AnonServer
 
getAuthorizationID() - Method in class com.swiftmq.impl.amqp.sasl.provider.PlainServer
 
getAvailable() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
getAverage() - Method in class com.swiftmq.impl.queue.standard.queue.QueueLatency
 
getBaseTx() - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredTransactionId
 
getBeforeImage() - Method in class com.swiftmq.impl.store.standard.log.DeleteLogAction
 
getBeforeImage() - Method in class com.swiftmq.impl.store.standard.log.UpdateLogAction
 
getBeforeImage() - Method in class com.swiftmq.impl.store.standard.log.UpdatePortionLogAction
 
getBody() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.Delivery
 
getBodyParts() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.MessageWrap
 
getBranchQualifier() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RecoveryRequest
 
getBranchQualifier() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RecoveryRequest
 
getBroker() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
getBrokerSubscriberId() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
getBuffer() - Method in class com.swiftmq.impl.mgmt.standard.po.ClientRequest
 
getByteCount() - Method in interface com.swiftmq.impl.net.netty.Countable
 
getByteCount() - Method in class com.swiftmq.impl.net.netty.CountableBufferedInputStream
 
getByteCount() - Method in class com.swiftmq.impl.net.netty.CountableBufferedOutputStream
 
getByteCount() - Method in class com.swiftmq.impl.net.netty.CountableInput
 
getByteCount() - Method in class com.swiftmq.impl.net.netty.CountableWrappedOutputStream
 
getCache() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getCacheReleaseListener() - Method in class com.swiftmq.impl.store.standard.log.LogRecord
 
getCacheSize() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getCacheSizeKB() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getCacheTable() - Method in interface com.swiftmq.impl.queue.standard.queue.Cache
 
getCacheTable() - Method in class com.swiftmq.impl.queue.standard.queue.CacheImpl
 
getCalendar() - Method in class com.swiftmq.impl.scheduler.standard.po.CalendarAdded
 
getCalendar() - Method in class com.swiftmq.impl.scheduler.standard.po.CalendarChanged
 
getCalendar() - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
getCalendar() - Method in class com.swiftmq.impl.scheduler.standard.ScheduleEntry
 
getCallback() - Method in class com.swiftmq.impl.store.standard.log.LogRecord
 
getChallenge() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ConnectReplyRequest
 
getChallenge() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectReplyRequest
 
getChallengeResponseFactory() - Method in class com.swiftmq.impl.jms.standard.JMSSwiftlet
 
getChannel() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler
 
getChannelHandler() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.Consumer
 
getChannelNo() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.ChannelHandler
 
getChannelNo() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendChannelClose
 
getClientDispatchId() - Method in class com.swiftmq.impl.jms.standard.v750.Consumer
 
getClientId() - Method in class com.swiftmq.impl.jms.standard.v750.JMSConnection
 
getClientId() - Method in class com.swiftmq.impl.mqtt.connection.MQTTConnection
 
getClientId() - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
getClientId() - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
Internal use.
getClientId() - Method in class com.swiftmq.impl.topic.standard.DurableSubscription
 
getClientListenerId() - Method in class com.swiftmq.impl.jms.standard.v750.Consumer
 
getClusteredQueueMetricCollection() - Method in class com.swiftmq.impl.queue.standard.cluster.DispatchPolicyRegistry
 
getClusteredQueueMetrics() - Method in interface com.swiftmq.impl.queue.standard.cluster.ClusteredQueueMetricCollection
 
getClusteredQueueMetrics() - Method in class com.swiftmq.impl.queue.standard.cluster.v700.ClusteredQueueMetricCollectionImpl
 
getClusteredQueueName() - Method in interface com.swiftmq.impl.queue.standard.cluster.ClusteredQueueMetric
 
getClusteredQueueName() - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
getClusteredQueueName() - Method in class com.swiftmq.impl.queue.standard.cluster.v700.ClusteredQueueMetricImpl
 
getCompositeStoreTransaction() - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredTransactionId
 
getCompositeStoreTransaction() - Method in class com.swiftmq.impl.queue.standard.composite.CompositeTransactionId
 
getCompositeStoreTransaction(Object) - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredQueue
 
getCompositeStoreTransaction(Object) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getCondition() - Method in exception com.swiftmq.impl.amqp.amqp.v01_00_00.EndWithErrorException
 
getConfig() - Method in class com.swiftmq.impl.mgmt.standard.po.SwiftletAdded
 
getConnection() - Method in class com.swiftmq.impl.amqp.VersionedConnection
 
getConnection() - Method in class com.swiftmq.impl.mqtt.connection.MQTTConnection
 
getConnection() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getConnection() - Method in class com.swiftmq.impl.routing.single.manager.event.ConnectionEvent
 
getConnection() - Method in class com.swiftmq.impl.routing.single.manager.po.POAddObject
 
getConnection() - Method in class com.swiftmq.impl.routing.single.manager.po.PORemoveObject
 
getConnection() - Method in class com.swiftmq.impl.routing.single.schedule.po.POConnectionAddedObject
 
getConnection() - Method in class com.swiftmq.impl.routing.single.schedule.po.POConnectionRemovedObject
 
getConnectionId() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getConnectionRoutes(RoutingConnection) - Method in class com.swiftmq.impl.routing.single.route.RouteTable
 
getConnectionTemplate() - Method in class com.swiftmq.impl.amqp.VersionedConnection
 
getConnectionTemplate() - Method in class com.swiftmq.impl.mqtt.connection.MQTTConnection
 
getConnectionTemplate(String) - Method in class com.swiftmq.impl.amqp.AMQPSwiftlet
 
getConnectionTemplate(String) - Method in class com.swiftmq.impl.mqtt.MQTTSwiftlet
 
getConnector(int) - Method in class com.swiftmq.impl.net.netty.scheduler.IOScheduler
 
getConsumedTotal() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getConsumedTotal() - Method in class com.swiftmq.impl.queue.standard.queue.QueueMetrics
 
getConsumer() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.SourceMessageProcessor
 
getConsumerCacheSize() - Method in class com.swiftmq.impl.jms.standard.v750.AsyncMessageProcessor
 
getConsumerTag() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.Consumer
 
getConsumingRate() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getConsumingRate() - Method in class com.swiftmq.impl.queue.standard.queue.QueueMetrics
 
getContentHeaderProperties() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.Delivery
 
getContentHeaderProperties() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.MessageWrap
 
getContext() - Method in class com.swiftmq.impl.mgmt.standard.CLIExecutorImpl
 
getContext() - Method in class com.swiftmq.impl.mgmt.standard.po.EntityAdded
 
getContext() - Method in class com.swiftmq.impl.mgmt.standard.po.EntityRemoved
 
getContext() - Method in class com.swiftmq.impl.mgmt.standard.po.PropertyChanged
 
getContext() - Static method in class com.swiftmq.impl.queue.standard.SwiftletContext
 
getContext() - Method in class com.swiftmq.impl.streams.processor.po.POFunctionCallback
 
getContext(Entity) - Method in class com.swiftmq.impl.mgmt.standard.jmx.JMXUtil
 
getCrFactory() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ConnectReplyRequest
 
getCrFactory() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectReplyRequest
 
getCurrent() - Static method in class com.swiftmq.impl.store.standard.pagedb.PageSize
 
getCurrentBytesKB() - Method in interface com.swiftmq.impl.queue.standard.queue.Cache
 
getCurrentBytesKB() - Method in class com.swiftmq.impl.queue.standard.queue.CacheImpl
 
getCurrentCacheSizeKB() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getCurrentCacheSizeMessages() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getCurrentMessages() - Method in interface com.swiftmq.impl.queue.standard.queue.Cache
 
getCurrentMessages() - Method in class com.swiftmq.impl.queue.standard.queue.CacheImpl
 
getCurrentMessageSize() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
getCurrentTx() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
getDateFrom() - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
getDateFrom() - Method in class com.swiftmq.impl.scheduler.standard.ScheduleEntry
 
getDateTo() - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
getDateTo() - Method in class com.swiftmq.impl.scheduler.standard.ScheduleEntry
 
getDefaultOutcome() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
getDefinedQueueNames() - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
getDelay() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ThrottleRequest
 
getDelay() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ThrottleRequest
 
getDeliveries() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendMessages
 
getDeliveryCount() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
getDeliveryCount() - Method in class com.swiftmq.impl.store.standard.index.QueueIndexEntry
 
getDeliveryCountSnd() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
getDeliveryMode() - Method in class com.swiftmq.impl.streams.comp.memory.QueueMemory
 
getDeliveryMode() - Method in class com.swiftmq.impl.streams.comp.memory.TempQueueMemory
 
getDeliveryRequest() - Method in class com.swiftmq.impl.routing.single.schedule.po.PODeliveredObject
 
getDeliveryStart() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendMessages
 
getDeploySpace(String) - Method in class com.swiftmq.impl.deploy.standard.DeploySwiftletImpl
 
getDescription() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendChannelClose
 
getDescription() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendClose
 
getDescription() - Method in exception com.swiftmq.impl.amqp.amqp.v01_00_00.EndWithErrorException
 
getDescription() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSendClose
 
getDescription() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSendEnd
 
getDescription() - Method in class com.swiftmq.impl.jms.standard.v750.AsyncMessageProcessor
 
getDescription() - Method in class com.swiftmq.impl.jndi.standard.QueueJNDIProcessor
 
getDescription() - Method in class com.swiftmq.impl.jndi.standard.TopicJNDIProcessor
 
getDescription() - Method in class com.swiftmq.impl.mgmt.standard.Listener
 
getDescription() - Method in class com.swiftmq.impl.mgmt.standard.MessageInterfaceListener
 
getDescription() - Method in class com.swiftmq.impl.queue.standard.cluster.Redispatcher
 
getDescription() - Method in class com.swiftmq.impl.queue.standard.jobs.MultiQueuePurgerJobFactory
 
getDescription() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueCleanupDLQJobFactory
 
getDescription() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueCleanupJobFactory
 
getDescription() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueMoverJobFactory
 
getDescription() - Method in class com.swiftmq.impl.queue.standard.jobs.QueuePurgerJobFactory
 
getDescription() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueResetJobFactory
 
getDescription() - Method in class com.swiftmq.impl.routing.single.jobs.RoutingConnectorJobFactory
 
getDescription() - Method in class com.swiftmq.impl.scheduler.standard.job.MessageSenderJobFactory
 
getDescription() - Method in class com.swiftmq.impl.store.standard.jobs.BackupJobFactory
 
getDescription() - Method in class com.swiftmq.impl.store.standard.jobs.ScanJobFactory
 
getDescription() - Method in class com.swiftmq.impl.store.standard.jobs.ShrinkJobFactory
 
getDescription() - Method in class com.swiftmq.impl.streams.jobs.StreamsJobFactory
 
getDescription() - Method in class com.swiftmq.impl.streams.StreamLibDeployer
 
getDescription() - Method in class com.swiftmq.impl.topic.standard.announce.TopicAnnounceReceiver
 
getDescription() - Method in class com.swiftmq.impl.topic.standard.jobs.DeleteDurableJobFactory
 
getDesiredCapabilities() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
getDestination() - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredTransactionId
 
getDestination() - Method in class com.swiftmq.impl.routing.single.RouteImpl
 
getDestination() - Method in class com.swiftmq.impl.streams.comp.io.Output
 
getDestination() - Method in class com.swiftmq.impl.streams.comp.io.QueueOutput
 
getDestination() - Method in class com.swiftmq.impl.streams.comp.io.TopicOutput
 
getDestination() - Method in class com.swiftmq.impl.topic.standard.announce.po.PODestinationActivated
 
getDestination() - Method in class com.swiftmq.impl.topic.standard.announce.po.PODestinationDeactivated
 
getDestination() - Method in class com.swiftmq.impl.topic.standard.announce.po.PODestinationRemoved
 
getDestination() - Method in class com.swiftmq.impl.topic.standard.announce.po.POVersionNoteToSend
 
getDestination() - Method in interface com.swiftmq.impl.topic.standard.announce.TopicInfo
 
getDestination() - Method in class com.swiftmq.impl.topic.standard.announce.v400.TopicInfoImpl
 
getDestination() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
getDestinationRouter() - Method in interface com.swiftmq.impl.routing.single.route.Route
 
getDestinationRouter() - Method in class com.swiftmq.impl.routing.single.route.v400.RouteImpl
 
getDispatchToken() - Method in class com.swiftmq.impl.jms.standard.v750.AsyncMessageProcessor
 
getDispatchToken() - Method in class com.swiftmq.impl.jndi.standard.QueueJNDIProcessor
 
getDispatchToken() - Method in class com.swiftmq.impl.jndi.standard.TopicJNDIProcessor
 
getDispatchToken() - Method in class com.swiftmq.impl.mgmt.standard.Listener
 
getDispatchToken() - Method in class com.swiftmq.impl.mgmt.standard.MessageInterfaceListener
 
getDispatchToken() - Method in class com.swiftmq.impl.queue.standard.cluster.Redispatcher
 
getDispatchToken() - Method in class com.swiftmq.impl.streams.StreamLibDeployer
 
getDispatchToken() - Method in class com.swiftmq.impl.topic.standard.announce.TopicAnnounceReceiver
 
getDumpId() - Method in class com.swiftmq.impl.queue.standard.cluster.v700.ClusteredQueueMetricCollectionImpl
 
getDumpId() - Method in class com.swiftmq.impl.queue.standard.cluster.v700.ClusteredQueueMetricImpl
 
getDumpId() - Method in class com.swiftmq.impl.queue.standard.cluster.v700.QueueMetricImpl
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.route.v400.RouteImpl
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.BulkRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.CloseStageQueueRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.DeliveryRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.KeepAliveRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.ProtocolReplyRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.ProtocolRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.SendRouteRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.StartStageRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.AdjustRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.AuthReplyRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.AuthRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.CommitReplyRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.CommitRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ConnectReplyRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ConnectRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RecoveryReplyRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RecoveryRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RollbackReplyRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RollbackRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RouteRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.StartDeliveryRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ThrottleRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.TransactionRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.AdjustRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.AuthReplyRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.AuthRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.CommitReplyRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.CommitRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectReplyRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.NonXACommitRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.NonXATransactionRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RecoveryReplyRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RecoveryRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RollbackReplyRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RollbackRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RouteRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.StartDeliveryRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ThrottleRequest
 
getDumpId() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.TransactionRequest
 
getDumpId() - Method in class com.swiftmq.impl.topic.standard.announce.v400.TopicInfoImpl
 
getDurability() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
getDurableFilename(String, String) - Static method in class com.swiftmq.impl.store.standard.DurableSubscriberStoreImpl
 
getDurableName() - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
Internal use.
getDurableName() - Method in class com.swiftmq.impl.topic.standard.DurableSubscription
 
getDurableStoreEntry() - Method in class com.swiftmq.impl.topic.standard.DurableSubscription
 
getDurableStoreEntry(String, String) - Method in class com.swiftmq.impl.store.standard.DurableSubscriberStoreImpl
 
getDurableSubscriberStore() - Method in class com.swiftmq.impl.store.standard.StoreSwiftletImpl
 
getDurableTopicName(String, ActiveLogin) - Method in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
getEntity() - Method in class com.swiftmq.impl.mgmt.standard.jmx.EntityMBean
 
getEntity() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getEntityListContext() - Method in class com.swiftmq.impl.mgmt.standard.po.PropertyChanged
 
getEntries() - Method in class com.swiftmq.impl.store.standard.index.Index
 
getErrorCondition() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendChannelClose
 
getErrorCondition() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendClose
 
getErrorCondition() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSendClose
 
getErrorCondition() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSendEnd
 
getEventLoop() - Method in class com.swiftmq.impl.jms.standard.v750.OutboundWriter
 
getException() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.SourceMessageProcessor
 
getException() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceMessageProcessor
 
getExpirationTime() - Method in class com.swiftmq.impl.queue.standard.queue.StoreId
 
getExpirationTime() - Method in class com.swiftmq.impl.store.standard.index.QueueIndexEntry
 
getExpiredMessage(Object, long) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getExpiryPolicy() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
getFactory() - Method in class com.swiftmq.impl.scheduler.standard.po.JobFactoryAdded
 
getFailedMethod() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendChannelClose
 
getFile() - Method in class com.swiftmq.impl.store.standard.log.AppendLogFile
 
getFile() - Method in interface com.swiftmq.impl.store.standard.log.LogFile
 
getFile() - Method in class com.swiftmq.impl.store.standard.log.ReuseLogFile
 
getFilename() - Method in interface com.swiftmq.impl.store.standard.swap.SwapFile
 
getFilename() - Method in class com.swiftmq.impl.store.standard.swap.SwapFileImpl
 
getFinishedListener() - Method in class com.swiftmq.impl.store.standard.processor.backup.po.StartBackup
 
getFirstFreePosition() - Method in class com.swiftmq.impl.store.standard.index.IndexPage
 
getFlowcontrolDelay() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
getFlowcontrolTimer() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
getFlushSize() - Method in class com.swiftmq.impl.store.standard.log.AppendLogFile
 
getFlushSize() - Method in interface com.swiftmq.impl.store.standard.log.LogFile
 
getFlushSize() - Method in class com.swiftmq.impl.store.standard.log.ReuseLogFile
 
getFrame() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POChannelFrameReceived
 
getFrame() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POConnectionFrameReceived
 
getFrame() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSessionFrameReceived
 
getFrame() - Method in class com.swiftmq.impl.amqp.sasl.v01_00_00.po.POSaslFrameReceived
 
getFunctionCallback() - Method in class com.swiftmq.impl.streams.processor.po.POFunctionCallback
 
getGlobalTxId() - Method in class com.swiftmq.impl.store.standard.xa.PrepareLogRecordImpl
 
getGrantedCommands(String) - Method in class com.swiftmq.impl.mgmt.standard.auth.Role
 
getGroup() - Method in class com.swiftmq.impl.auth.standard.User
 
getGroup(String) - Method in class com.swiftmq.impl.threadpool.standard.group.GroupRegistry
 
getGroupName() - Method in class com.swiftmq.impl.scheduler.standard.po.JobFactoryAdded
 
getGroupName() - Method in class com.swiftmq.impl.scheduler.standard.po.JobFactoryRemoved
 
getGroups() - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
getHandle() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
getHeuristicCompletedXids() - Method in class com.swiftmq.impl.xa.standard.XAResourceManagerSwiftletImpl
 
getHopCount() - Method in interface com.swiftmq.impl.routing.single.route.Route
 
getHopCount() - Method in class com.swiftmq.impl.routing.single.route.v400.RouteImpl
 
getHostname() - Method in class com.swiftmq.impl.net.netty.scheduler.IntraVMServerEndpointImpl
 
getHostname() - Method in class com.swiftmq.impl.net.netty.scheduler.NettyConnection
 
getImpl() - Method in class com.swiftmq.impl.streams.comp.message.Message
Internal use only.
getInboundHandler() - Method in class com.swiftmq.impl.jms.standard.v750.JMSConnection
 
getInboundHandler() - Method in interface com.swiftmq.impl.jms.standard.VersionedJMSConnection
 
getIndexEntry(MessageIndex) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getInput() - Method in class com.swiftmq.impl.streams.processor.ManagementProcessor
 
getInput() - Method in class com.swiftmq.impl.streams.processor.QueueMessageProcessor
 
getInputs() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
getInputStream() - Method in class com.swiftmq.impl.net.netty.scheduler.IntraVMServerEndpointImpl
 
getInputStream() - Method in class com.swiftmq.impl.net.netty.scheduler.NettyConnection
 
getInstalledBundles() - Method in class com.swiftmq.impl.deploy.standard.DeploySpaceImpl
 
getInterval() - Method in class com.swiftmq.impl.streams.processor.po.POCollect
 
getJDBCLookups() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
getJmsConnection() - Method in class com.swiftmq.impl.jms.standard.VersionSelector
 
getJmsMessage() - Method in class com.swiftmq.impl.mqtt.po.POSendMessage
 
getJNDIObject(String) - Method in class com.swiftmq.impl.jndi.standard.JNDISwiftletImpl
 
getJNDIObjectName(QueueImpl) - Method in class com.swiftmq.impl.jndi.standard.JNDISwiftletImpl
 
getJobException() - Method in class com.swiftmq.impl.scheduler.standard.po.JobTerminated
 
getJobFactoryNames() - Method in class com.swiftmq.impl.scheduler.standard.JobGroupImpl
 
getJobGroup() - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
getJobGroup(String) - Method in class com.swiftmq.impl.scheduler.standard.SchedulerSwiftletImpl
 
getJobInstance() - Method in class com.swiftmq.impl.queue.standard.jobs.MultiQueuePurgerJobFactory
 
getJobInstance() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueCleanupDLQJobFactory
 
getJobInstance() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueCleanupJobFactory
 
getJobInstance() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueMoverJobFactory
 
getJobInstance() - Method in class com.swiftmq.impl.queue.standard.jobs.QueuePurgerJobFactory
 
getJobInstance() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueResetJobFactory
 
getJobInstance() - Method in class com.swiftmq.impl.routing.single.jobs.RoutingConnectorJobFactory
 
getJobInstance() - Method in class com.swiftmq.impl.scheduler.standard.job.MessageSenderJobFactory
 
getJobInstance() - Method in class com.swiftmq.impl.store.standard.jobs.BackupJobFactory
 
getJobInstance() - Method in class com.swiftmq.impl.store.standard.jobs.ScanJobFactory
 
getJobInstance() - Method in class com.swiftmq.impl.store.standard.jobs.ShrinkJobFactory
 
getJobInstance() - Method in class com.swiftmq.impl.streams.jobs.StreamsJobFactory
 
getJobInstance() - Method in class com.swiftmq.impl.topic.standard.jobs.DeleteDurableJobFactory
 
getJobName() - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
getJobParameter(String) - Method in class com.swiftmq.impl.queue.standard.jobs.MultiQueuePurgerJobFactory
 
getJobParameter(String) - Method in class com.swiftmq.impl.queue.standard.jobs.QueueCleanupDLQJobFactory
 
getJobParameter(String) - Method in class com.swiftmq.impl.queue.standard.jobs.QueueCleanupJobFactory
 
getJobParameter(String) - Method in class com.swiftmq.impl.queue.standard.jobs.QueueMoverJobFactory
 
getJobParameter(String) - Method in class com.swiftmq.impl.queue.standard.jobs.QueuePurgerJobFactory
 
getJobParameter(String) - Method in class com.swiftmq.impl.queue.standard.jobs.QueueResetJobFactory
 
getJobParameter(String) - Method in class com.swiftmq.impl.routing.single.jobs.RoutingConnectorJobFactory
 
getJobParameter(String) - Method in class com.swiftmq.impl.scheduler.standard.job.MessageSenderJobFactory
 
getJobParameter(String) - Method in class com.swiftmq.impl.store.standard.jobs.BackupJobFactory
 
getJobParameter(String) - Method in class com.swiftmq.impl.store.standard.jobs.ScanJobFactory
 
getJobParameter(String) - Method in class com.swiftmq.impl.store.standard.jobs.ShrinkJobFactory
 
getJobParameter(String) - Method in class com.swiftmq.impl.streams.jobs.StreamsJobFactory
 
getJobParameter(String) - Method in class com.swiftmq.impl.topic.standard.jobs.DeleteDurableJobFactory
 
getJobParameters() - Method in class com.swiftmq.impl.queue.standard.jobs.MultiQueuePurgerJobFactory
 
getJobParameters() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueCleanupDLQJobFactory
 
getJobParameters() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueCleanupJobFactory
 
getJobParameters() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueMoverJobFactory
 
getJobParameters() - Method in class com.swiftmq.impl.queue.standard.jobs.QueuePurgerJobFactory
 
getJobParameters() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueResetJobFactory
 
getJobParameters() - Method in class com.swiftmq.impl.routing.single.jobs.RoutingConnectorJobFactory
 
getJobParameters() - Method in class com.swiftmq.impl.scheduler.standard.job.MessageSenderJobFactory
 
getJobParameters() - Method in class com.swiftmq.impl.store.standard.jobs.BackupJobFactory
 
getJobParameters() - Method in class com.swiftmq.impl.store.standard.jobs.ScanJobFactory
 
getJobParameters() - Method in class com.swiftmq.impl.store.standard.jobs.ShrinkJobFactory
 
getJobParameters() - Method in class com.swiftmq.impl.streams.jobs.StreamsJobFactory
 
getJobParameters() - Method in class com.swiftmq.impl.topic.standard.jobs.DeleteDurableJobFactory
 
getJournal() - Method in class com.swiftmq.impl.store.standard.index.Index
 
getJournal() - Method in class com.swiftmq.impl.store.standard.log.LogRecord
 
getJsonPaths(String) - Method in class com.swiftmq.impl.streams.ContentTransformer
 
getKeepaliveInterval() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getKeepAliveInterval() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ConnectReplyRequest
 
getKeepAliveInterval() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectReplyRequest
 
getKey() - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupEntry
 
getKey() - Method in interface com.swiftmq.impl.routing.single.route.Route
 
getKey() - Method in class com.swiftmq.impl.routing.single.route.v400.RouteImpl
 
getKey() - Method in class com.swiftmq.impl.store.standard.index.IndexEntry
 
getKeyList() - Method in class com.swiftmq.impl.store.standard.xa.PrepareLogRecordImpl
 
getLastAccessTime() - Method in class com.swiftmq.impl.store.standard.cache.Slot
 
getLastCollect() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POConnectionCollect
 
getLastCollect() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSessionCollect
 
getLastCollect() - Method in class com.swiftmq.impl.jms.standard.v750.CollectRequest
 
getLastCollect() - Method in class com.swiftmq.impl.mqtt.po.POCollect
 
getLastDelay() - Method in class com.swiftmq.impl.queue.standard.queue.FlowControllerImpl
 
getLastDeliveryId() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
getLastDeliveryState() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
getLastDispatchTime() - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupEntry
 
getLastException() - Method in class com.swiftmq.impl.streams.StreamContext
 
getLastHop() - Method in interface com.swiftmq.impl.routing.single.route.Route
 
getLastHop() - Method in class com.swiftmq.impl.routing.single.route.v400.RouteImpl
 
getLastReceivedLinkCredit() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
getLastUse() - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
getLatency(long) - Method in class com.swiftmq.impl.queue.standard.queue.StoreId
 
getLength() - Method in class com.swiftmq.impl.routing.single.schedule.po.PODeliverObject
 
getLength() - Method in class com.swiftmq.impl.store.standard.index.IndexEntry
 
getLength() - Method in class com.swiftmq.impl.store.standard.index.MessagePage
 
getLength() - Method in class com.swiftmq.impl.store.standard.index.QueueIndexEntry
 
getLength() - Method in class com.swiftmq.impl.store.standard.index.RootIndexEntry
 
getLink() - Method in exception com.swiftmq.impl.amqp.amqp.v01_00_00.LinkEndException
 
getLinkCredit() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
getLinkCredit() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
getListener(int) - Method in class com.swiftmq.impl.net.netty.scheduler.IOScheduler
 
getLocalAddress() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
getLocalDestination() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
getLocalMetric() - Method in interface com.swiftmq.impl.queue.standard.cluster.DispatchPolicy
 
getLocalMetric() - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
getLocalMetric() - Method in class com.swiftmq.impl.queue.standard.cluster.RoundRobinDispatchPolicy
 
getLogFile() - Method in interface com.swiftmq.impl.store.standard.log.LogManager
 
getLogFile() - Method in class com.swiftmq.impl.store.standard.log.LogManagerEventProcessor
 
getLoginId() - Method in class com.swiftmq.impl.auth.standard.LoginId
 
getLogRecord() - Method in class com.swiftmq.impl.store.standard.index.IndexPage
 
getLogType() - Method in class com.swiftmq.impl.store.standard.log.AbortLogRecord
 
getLogType() - Method in class com.swiftmq.impl.store.standard.log.CommitLogRecord
 
getLogType() - Method in class com.swiftmq.impl.store.standard.log.LogRecord
 
getLogType() - Method in class com.swiftmq.impl.store.standard.log.StartLogRecord
 
getMagic() - Method in class com.swiftmq.impl.store.standard.log.LogRecord
 
getMailservers() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
getManagementProcessor() - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
Internal use.
getManagementProcessor() - Method in class com.swiftmq.impl.streams.processor.po.POMgmtMessage
 
getMatchedTopics(String[]) - Method in class com.swiftmq.impl.topic.standard.TopicBroker
 
getMaxBulkSize() - Method in class com.swiftmq.impl.jms.standard.v750.AsyncMessageProcessor
 
getMaxBytesKB() - Method in interface com.swiftmq.impl.queue.standard.queue.Cache
 
getMaxBytesKB() - Method in class com.swiftmq.impl.queue.standard.queue.CacheImpl
 
getMaxFileSize() - Method in class com.swiftmq.impl.trace.standard.TraceSwiftletImpl
 
getMaxFlowControlDelay() - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
getMaxFrameSize() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandler
 
getMaxFrameSize() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.AMQPHandler
 
getMaxKey() - Method in class com.swiftmq.impl.store.standard.index.Index
 
getMaxLength() - Method in interface com.swiftmq.impl.store.standard.swap.SwapFile
 
getMaxLength() - Method in class com.swiftmq.impl.store.standard.swap.SwapFileImpl
 
getMaxMessages() - Method in interface com.swiftmq.impl.queue.standard.queue.Cache
 
getMaxMessages() - Method in class com.swiftmq.impl.queue.standard.queue.CacheImpl
 
getMaxRuntime() - Method in class com.swiftmq.impl.scheduler.standard.po.JobStart
 
getMaxRuntime() - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
getMBeanInfo() - Method in class com.swiftmq.impl.mgmt.standard.jmx.EntityMBean
 
getMechanismName() - Method in class com.swiftmq.impl.amqp.sasl.provider.AnonServer
 
getMechanismName() - Method in class com.swiftmq.impl.amqp.sasl.provider.PlainServer
 
getMechanismNames(Map) - Method in class com.swiftmq.impl.amqp.sasl.provider.SaslServerFactoryImpl
 
getMemories() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
getMemoryGroups() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
getMessage() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.Delivery
 
getMessage() - Method in class com.swiftmq.impl.mqtt.po.POConnect
 
getMessage() - Method in class com.swiftmq.impl.mqtt.po.PODisconnect
 
getMessage() - Method in class com.swiftmq.impl.mqtt.po.POPingReq
 
getMessage() - Method in class com.swiftmq.impl.mqtt.po.POProtocolError
 
getMessage() - Method in class com.swiftmq.impl.mqtt.po.POPubAck
 
getMessage() - Method in class com.swiftmq.impl.mqtt.po.POPubComp
 
getMessage() - Method in class com.swiftmq.impl.mqtt.po.POPublish
 
getMessage() - Method in class com.swiftmq.impl.mqtt.po.POPubRec
 
getMessage() - Method in class com.swiftmq.impl.mqtt.po.POPubRel
 
getMessage() - Method in class com.swiftmq.impl.mqtt.po.POSubscribe
 
getMessage() - Method in class com.swiftmq.impl.mqtt.po.POUnsubscribe
 
getMessage() - Method in class com.swiftmq.impl.scheduler.standard.po.JobTerminated
 
getMessage() - Method in class com.swiftmq.impl.streams.processor.po.POMgmtMessage
 
getMessage() - Method in class com.swiftmq.impl.streams.processor.po.POWireTapMessage
 
getMessage() - Method in class com.swiftmq.impl.streams.processor.QueueMessageProcessor
 
getMessage(Object) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getMessage(Object, long) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getMessage(Object, Selector) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getMessage(Object, Selector, int) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getMessage(Object, Selector, int, long) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getMessage(Object, Selector, long) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getMessageByIndex(MessageIndex) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getMessageIndex() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.Delivery
 
getMessageIndex() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.Delivery
 
getMessageList() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.TransactionRequest
 
getMessageList() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.NonXATransactionRequest
 
getMessageList() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.TransactionRequest
 
getMessagePageRefs() - Method in class com.swiftmq.impl.store.standard.log.LogRecord
 
getMessageProcessor() - Method in class com.swiftmq.impl.jms.standard.v750.Consumer
 
getMessageProcessor() - Method in class com.swiftmq.impl.jms.standard.v750.RegisterMessageProcessor
 
getMessageProcessor() - Method in class com.swiftmq.impl.jms.standard.v750.RunMessageProcessor
 
getMessageProcessor() - Method in interface com.swiftmq.impl.streams.comp.io.DestinationInput
Internal use.
getMessageProcessor() - Method in class com.swiftmq.impl.streams.comp.io.QueueInput
 
getMessageProcessor() - Method in class com.swiftmq.impl.streams.comp.io.QueueWireTapInput
 
getMessageProcessor() - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
 
getMessageProcessor() - Method in class com.swiftmq.impl.streams.processor.po.POMessage
 
getMetaData() - Method in class com.swiftmq.impl.net.netty.scheduler.TCPConnector
 
getMetaData() - Method in class com.swiftmq.impl.net.netty.scheduler.TCPListener
 
getMinHopCount() - Method in class com.swiftmq.impl.routing.single.schedule.DefaultScheduler.ConnectionEntry
 
getMqttConnection() - Method in class com.swiftmq.impl.mqtt.connection.MQTTConnection
 
getMqttConnection() - Method in interface com.swiftmq.impl.mqtt.session.AssociateSessionCallback
 
getMqttConnection() - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
getMsgSize() - Method in class com.swiftmq.impl.queue.standard.queue.StoreId
 
getMsgsReceived() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler
 
getMsgsReceived() - Method in class com.swiftmq.impl.jms.standard.v750.SessionContext
 
getMsgsReceived() - Method in class com.swiftmq.impl.mqtt.pubsub.Subscription
 
getMsgsReceived() - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
getMsgsSent() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler
 
getMsgsSent() - Method in class com.swiftmq.impl.jms.standard.v750.SessionContext
 
getMsgsSent() - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
getMyConnection() - Method in class com.swiftmq.impl.jms.standard.v750.Session
 
getMySessionHandler() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
getName() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
getName() - Method in class com.swiftmq.impl.auth.standard.Group
 
getName() - Method in class com.swiftmq.impl.auth.standard.User
 
getName() - Method in class com.swiftmq.impl.jndi.standard.JNDIReplication
 
getName() - Method in class com.swiftmq.impl.mgmt.standard.po.Disconnect
 
getName() - Method in class com.swiftmq.impl.mgmt.standard.po.EntityAdded
 
getName() - Method in class com.swiftmq.impl.mgmt.standard.po.EntityRemoved
 
getName() - Method in class com.swiftmq.impl.mgmt.standard.po.PropertyChanged
 
getName() - Method in class com.swiftmq.impl.mgmt.standard.po.RouterAvailable
 
getName() - Method in class com.swiftmq.impl.mgmt.standard.po.RouterUnavailable
 
getName() - Method in class com.swiftmq.impl.mgmt.standard.po.SwiftletAdded
 
getName() - Method in class com.swiftmq.impl.mgmt.standard.po.SwiftletRemoved
 
getName() - Method in class com.swiftmq.impl.queue.standard.jobs.MultiQueuePurgerJobFactory
 
getName() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueCleanupDLQJobFactory
 
getName() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueCleanupJobFactory
 
getName() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueMoverJobFactory
 
getName() - Method in class com.swiftmq.impl.queue.standard.jobs.QueuePurgerJobFactory
 
getName() - Method in class com.swiftmq.impl.queue.standard.jobs.QueueResetJobFactory
 
getName() - Method in class com.swiftmq.impl.routing.single.jobs.RoutingConnectorJobFactory
 
getName() - Method in class com.swiftmq.impl.scheduler.standard.job.MessageSenderJobFactory
 
getName() - Method in class com.swiftmq.impl.scheduler.standard.JobGroupImpl
 
getName() - Method in class com.swiftmq.impl.scheduler.standard.po.CalendarRemoved
 
getName() - Method in class com.swiftmq.impl.scheduler.standard.po.JobFactoryAdded
 
getName() - Method in class com.swiftmq.impl.scheduler.standard.po.JobFactoryRemoved
 
getName() - Method in class com.swiftmq.impl.scheduler.standard.po.JobStart
 
getName() - Method in class com.swiftmq.impl.scheduler.standard.po.JobStop
 
getName() - Method in class com.swiftmq.impl.scheduler.standard.po.JobTerminated
 
getName() - Method in class com.swiftmq.impl.scheduler.standard.po.ScheduleRemoved
 
getName() - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
getName() - Method in class com.swiftmq.impl.scheduler.standard.ScheduleEntry
 
getName() - Method in class com.swiftmq.impl.scheduler.standard.SchedulerCalendar
 
getName() - Method in class com.swiftmq.impl.store.standard.jobs.BackupJobFactory
 
getName() - Method in class com.swiftmq.impl.store.standard.jobs.ScanJobFactory
 
getName() - Method in class com.swiftmq.impl.store.standard.jobs.ShrinkJobFactory
 
getName() - Method in interface com.swiftmq.impl.streams.comp.io.Input
Returns the name of this Input.
getName() - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
 
getName() - Method in class com.swiftmq.impl.streams.comp.io.QueueInput
 
getName() - Method in class com.swiftmq.impl.streams.comp.io.QueueWireTapInput
 
getName() - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
 
getName() - Method in class com.swiftmq.impl.streams.jobs.StreamsJobFactory
 
getName() - Method in class com.swiftmq.impl.threadpool.standard.group.Group
 
getName() - Method in class com.swiftmq.impl.topic.standard.jobs.DeleteDurableJobFactory
 
getNegotiatedProperty(String) - Method in class com.swiftmq.impl.amqp.sasl.provider.AnonServer
 
getNegotiatedProperty(String) - Method in class com.swiftmq.impl.amqp.sasl.provider.PlainServer
 
getNewDelay() - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredQueueFlowController
 
getNewDelay() - Method in class com.swiftmq.impl.queue.standard.composite.CompositeQueueFlowController
 
getNewDelay() - Method in class com.swiftmq.impl.queue.standard.queue.FlowControllerImpl
 
getNewDelay() - Method in class com.swiftmq.impl.topic.standard.TopicFlowController
 
getNewGenerations() - Method in class com.swiftmq.impl.store.standard.processor.backup.po.ChangeGenerations
 
getNewPath() - Method in class com.swiftmq.impl.store.standard.processor.backup.po.ChangePath
 
getNextConnection() - Method in class com.swiftmq.impl.routing.single.schedule.DefaultScheduler
 
getNextConnection() - Method in class com.swiftmq.impl.routing.single.schedule.RoundRobinScheduler
 
getNextConnection() - Method in class com.swiftmq.impl.routing.single.schedule.Scheduler
 
getNextDeliveryTag() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.ChannelHandler
 
getNextJobStart(int, Calendar, Map) - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
getNextMsgId() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getNextPage() - Method in class com.swiftmq.impl.store.standard.index.IndexPage
 
getNextPage() - Method in class com.swiftmq.impl.store.standard.index.MessagePage
 
getNextPO() - Method in class com.swiftmq.impl.store.standard.processor.backup.po.ScanSaveSets
 
getNextReceiveQueue() - Method in interface com.swiftmq.impl.queue.standard.cluster.DispatchPolicy
 
getNextReceiveQueue() - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
getNextReceiveQueue() - Method in class com.swiftmq.impl.queue.standard.cluster.RoundRobinDispatchPolicy
 
getNextSendQueue() - Method in interface com.swiftmq.impl.queue.standard.cluster.DispatchPolicy
 
getNextSendQueue() - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
getNextSendQueue() - Method in class com.swiftmq.impl.queue.standard.cluster.RoundRobinDispatchPolicy
 
getNextSendQueue(MessageImpl) - Method in interface com.swiftmq.impl.queue.standard.cluster.DispatchPolicy
 
getNextSendQueue(MessageImpl) - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
getNextSendQueue(MessageImpl) - Method in class com.swiftmq.impl.queue.standard.cluster.RoundRobinDispatchPolicy
 
getNextStart(int, Calendar) - Method in class com.swiftmq.impl.scheduler.standard.AtSchedule
 
getNextStart(int, Calendar) - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
getnFree() - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
getNonPersistentStore(String) - Method in class com.swiftmq.impl.store.standard.StoreSwiftletImpl
 
getNumberConnections() - Method in class com.swiftmq.impl.auth.standard.User
 
getNumberConnections() - Method in class com.swiftmq.impl.net.netty.ConnectionManagerImpl
 
getNumberConnections() - Method in class com.swiftmq.impl.routing.single.schedule.DefaultScheduler
 
getNumberConnections() - Method in class com.swiftmq.impl.routing.single.schedule.Scheduler
 
getNumberEntries() - Method in class com.swiftmq.impl.store.standard.index.IndexPage
 
getNumberFileGenerations() - Method in class com.swiftmq.impl.trace.standard.TraceSwiftletImpl
 
getNumberMessages() - Method in interface com.swiftmq.impl.store.standard.swap.SwapFile
 
getNumberMessages() - Method in class com.swiftmq.impl.store.standard.swap.SwapFileImpl
 
getNumberPages() - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
getNumberQueueMessages() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getNumberRoutes() - Method in class com.swiftmq.impl.routing.single.schedule.DefaultScheduler.ConnectionEntry
 
getNumberSubscriberQueueMessages() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
getNumberSubscriptions() - Method in interface com.swiftmq.impl.topic.standard.announce.TopicInfo
 
getNumberSubscriptions() - Method in class com.swiftmq.impl.topic.standard.announce.v400.TopicInfoImpl
 
getNumberThreads() - Method in class com.swiftmq.impl.net.netty.scheduler.TaskExecutor
 
getNumberValidEntries() - Method in class com.swiftmq.impl.store.standard.index.IndexPage
 
getObjectName() - Method in class com.swiftmq.impl.mgmt.standard.jmx.EntityMBean
 
getOfferedCapabilities() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
getOfferedCapabilitiesArray() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
getOffset() - Method in class com.swiftmq.impl.store.standard.log.UpdatePortionLogAction
 
getOriginalQueueName() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.Consumer
 
getOutboundQueue() - Method in class com.swiftmq.impl.mqtt.connection.MQTTConnection
 
getOutboundQueue() - Method in class com.swiftmq.impl.routing.single.connection.OutboundWriter
 
getOutboundQueue() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getOutboundQueueName() - Method in class com.swiftmq.impl.routing.single.RouteImpl
 
getOutputs() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
getOutputStream() - Method in class com.swiftmq.impl.net.netty.scheduler.IntraVMServerEndpointImpl
 
getOutputStream() - Method in class com.swiftmq.impl.net.netty.scheduler.NettyConnection
 
getPage() - Method in class com.swiftmq.impl.store.standard.index.IndexPage
 
getPageNo() - Method in class com.swiftmq.impl.store.standard.log.DeleteLogAction
 
getPageNo() - Method in class com.swiftmq.impl.store.standard.log.InsertLogAction
 
getPageNo() - Method in class com.swiftmq.impl.store.standard.log.UpdatePortionLogAction
 
getParameters() - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
getPassword() - Method in class com.swiftmq.impl.auth.standard.User
 
getPassword() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getPassword(String) - Method in class com.swiftmq.impl.auth.standard.AuthenticationSwiftletImpl
 
getPath() - Method in class com.swiftmq.impl.store.standard.swap.SwapFileImpl
 
getPersistentKey() - Method in class com.swiftmq.impl.queue.standard.queue.StoreId
 
getPersistentStore(String) - Method in class com.swiftmq.impl.store.standard.StoreSwiftletImpl
 
getPort() - Method in class com.swiftmq.impl.net.netty.scheduler.NettyConnection
 
getPosition() - Method in class com.swiftmq.impl.store.standard.log.AppendLogFile
 
getPosition() - Method in interface com.swiftmq.impl.store.standard.log.LogFile
 
getPosition() - Method in class com.swiftmq.impl.store.standard.log.ReuseLogFile
 
getPreparationTime() - Method in class com.swiftmq.impl.store.standard.xa.PrepareLogRecordImpl
 
getPreparedXids() - Method in class com.swiftmq.impl.store.standard.xa.PreparedLog
 
getPreparedXids() - Method in class com.swiftmq.impl.xa.standard.XAResourceManagerSwiftletImpl
 
getPreparedXids(XidFilter) - Method in class com.swiftmq.impl.xa.standard.XAResourceManagerSwiftletImpl
 
getPrepareLogRecords() - Method in class com.swiftmq.impl.store.standard.StoreSwiftletImpl
 
getPrevPage() - Method in class com.swiftmq.impl.store.standard.index.IndexPage
 
getPrevPage() - Method in class com.swiftmq.impl.store.standard.index.MessagePage
 
getPriority() - Method in class com.swiftmq.impl.store.standard.index.QueueIndexEntry
 
getProducedTotal() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getProducedTotal() - Method in class com.swiftmq.impl.queue.standard.queue.QueueMetrics
 
getProducingRate() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getProducingRate() - Method in class com.swiftmq.impl.queue.standard.queue.QueueMetrics
 
getPropIncludes() - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
Internal use only.
getProtocolVersion() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getProtocolVersions() - Static method in class com.swiftmq.impl.routing.single.connection.stage.StageFactory
 
getProtocolVersions() - Method in class com.swiftmq.impl.routing.single.smqpr.ProtocolRequest
 
getProtocolVersionSelected() - Method in class com.swiftmq.impl.routing.single.smqpr.ProtocolReplyRequest
 
getPublish() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.MessageWrap
 
getQos() - Method in class com.swiftmq.impl.mqtt.po.POSendMessage
 
getQueueEntity() - Method in class com.swiftmq.impl.queue.standard.queue.ActiveQueueImpl
 
getQueueForInternalUse(String) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
getQueueForInternalUse(String, boolean) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
getQueueIndex() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getQueueIndex() - Method in class com.swiftmq.impl.store.standard.PersistentStoreImpl
 
getQueueIndex(int) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
getQueueIndex(String) - Method in class com.swiftmq.impl.store.standard.index.RootIndex
 
getQueueMetrics() - Method in interface com.swiftmq.impl.queue.standard.cluster.ClusteredQueueMetric
 
getQueueMetrics() - Method in class com.swiftmq.impl.queue.standard.cluster.v700.ClusteredQueueMetricImpl
 
getQueueName() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.Consumer
 
getQueueName() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
getQueueName() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
getQueueName() - Method in class com.swiftmq.impl.jms.standard.v750.TopicConsumer
 
getQueueName() - Method in class com.swiftmq.impl.jms.standard.v750.TopicDurableConsumer
 
getQueueName() - Method in class com.swiftmq.impl.mgmt.standard.po.ClientRequest
 
getQueueName() - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupEntry
 
getQueueName() - Method in interface com.swiftmq.impl.queue.standard.cluster.QueueMetric
 
getQueueName() - Method in class com.swiftmq.impl.queue.standard.cluster.v700.QueueMetricImpl
 
getQueueName() - Method in class com.swiftmq.impl.routing.single.schedule.Scheduler
 
getQueueName() - Method in class com.swiftmq.impl.store.standard.xa.PrepareLogRecordImpl
 
getQueueName() - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
Internal use.
getQueueName() - Method in class com.swiftmq.impl.streams.comp.memory.QueueMemory
 
getQueueName() - Method in class com.swiftmq.impl.topic.standard.DurableSubscription
 
getQueueReceiver() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
getQueueReceiver() - Method in interface com.swiftmq.impl.amqp.amqp.v01_00_00.transaction.QueueReceiverProvider
 
getQueueSender() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
getQueueSender() - Method in interface com.swiftmq.impl.amqp.amqp.v01_00_00.transaction.QueueSenderProvider
 
getQueuesForXid(byte[]) - Method in class com.swiftmq.impl.store.standard.xa.PreparedLog
 
getRcvSettleMode() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
getReadTransaction() - Method in class com.swiftmq.impl.jms.standard.v750.Consumer
 
getRecommended() - Static method in class com.swiftmq.impl.store.standard.pagedb.PageSize
 
getReconnectInterval() - Method in class com.swiftmq.impl.jndi.standard.JNDIReplication
 
getRefCount() - Method in class com.swiftmq.impl.store.standard.index.MessagePageReference
 
getReference(Integer, boolean) - Method in class com.swiftmq.impl.store.standard.index.ReferenceMap
 
getRemoteAddress() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
getRemoteHandle() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
getRemoteHostname() - Method in class com.swiftmq.impl.amqp.VersionedConnection
 
getRemoteHostname() - Method in class com.swiftmq.impl.jms.standard.v750.JMSConnection
 
getRemoteHostname() - Method in class com.swiftmq.impl.mqtt.connection.MQTTConnection
 
getRemoteHostName() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getResourceLimitGroup() - Method in class com.swiftmq.impl.auth.standard.User
 
getResourceName() - Method in class com.swiftmq.impl.auth.standard.ResourceGrant
 
getResponse() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.AuthRequest
 
getResponse() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.AuthRequest
 
getRootPageNo() - Method in class com.swiftmq.impl.store.standard.index.Index
 
getRootPageNo() - Method in class com.swiftmq.impl.store.standard.index.IndexEntry
 
getRootTopic() - Method in class com.swiftmq.impl.topic.standard.TopicBroker
 
getRoute() - Method in class com.swiftmq.impl.routing.single.route.po.PORouteObject
 
getRoute() - Method in class com.swiftmq.impl.routing.single.smqpr.SendRouteRequest
 
getRoute() - Method in class com.swiftmq.impl.topic.standard.announce.po.PODestinationAdded
 
getRoute(DumpableFactory) - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RouteRequest
 
getRoute(DumpableFactory) - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RouteRequest
 
getRouteConverter() - Method in class com.swiftmq.impl.routing.single.route.RouteExchanger
 
getRouterName() - Method in interface com.swiftmq.impl.queue.standard.cluster.ClusteredQueueMetricCollection
 
getRouterName() - Method in interface com.swiftmq.impl.queue.standard.cluster.QueueMetric
 
getRouterName() - Method in class com.swiftmq.impl.queue.standard.cluster.v700.ClusteredQueueMetricCollectionImpl
 
getRouterName() - Method in class com.swiftmq.impl.queue.standard.cluster.v700.QueueMetricImpl
 
getRouterName() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getRouterName() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ConnectReplyRequest
 
getRouterName() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ConnectRequest
 
getRouterName() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectReplyRequest
 
getRouterName() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectRequest
 
getRouterName() - Method in interface com.swiftmq.impl.topic.standard.announce.TopicInfo
 
getRouterName() - Method in class com.swiftmq.impl.topic.standard.announce.v400.TopicInfoImpl
 
getRoutingConnection() - Method in class com.swiftmq.impl.routing.single.route.po.POConnectionActivatedObject
 
getRoutingConnection() - Method in class com.swiftmq.impl.routing.single.route.po.POConnectionRemoveObject
 
getRoutingConnection() - Method in interface com.swiftmq.impl.routing.single.route.Route
 
getRoutingConnection() - Method in class com.swiftmq.impl.routing.single.route.v400.RouteImpl
 
getRoutingConnection() - Method in class com.swiftmq.impl.routing.single.schedule.DefaultScheduler.ConnectionEntry
 
getRoutingConnections() - Method in class com.swiftmq.impl.routing.single.route.RouteTable
 
getRunnable() - Method in class com.swiftmq.impl.streams.processor.po.POExecute
 
getSchedule() - Method in class com.swiftmq.impl.scheduler.standard.po.ScheduleAdded
 
getSchedule() - Method in class com.swiftmq.impl.scheduler.standard.po.ScheduleChanged
 
getScheduler() - Method in class com.swiftmq.impl.routing.single.RouteImpl
 
getScheduler(String) - Method in class com.swiftmq.impl.routing.single.schedule.SchedulerRegistry
 
getSelector() - Method in class com.swiftmq.impl.jms.standard.v750.Consumer
 
getSelector() - Method in interface com.swiftmq.impl.streams.comp.io.DestinationInput
Returns the associated JMS Message Selector
getSelector() - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
Internal use only.
getSelector() - Method in class com.swiftmq.impl.streams.comp.io.QueueInput
 
getSelector() - Method in class com.swiftmq.impl.streams.comp.io.QueueWireTapInput
Internal use.
getSelector() - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
 
getSelector() - Method in class com.swiftmq.impl.topic.standard.DurableSubscription
 
getSelector() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
getSemaphore() - Method in class com.swiftmq.impl.routing.single.smqpr.CloseStageQueueRequest
 
getSemaphore() - Method in class com.swiftmq.impl.store.standard.log.LogRecord
 
getSequenceNo() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.TransactionRequest
 
getSequenceNo() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.NonXACommitRequest
 
getSequenceNo() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.NonXATransactionRequest
 
getSequenceNo() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.TransactionRequest
 
getSession() - Method in class com.swiftmq.impl.mqtt.po.POSessionAssociated
 
getSessionHandlerForRemoteChannel(int) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.AMQPHandler
 
getSessionStoreEntry() - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
getShutdownSemaphore() - Method in class com.swiftmq.impl.amqp.AMQPSwiftlet
 
getShutdownSemaphore() - Method in class com.swiftmq.impl.jms.standard.JMSSwiftlet
 
getShutdownSemaphore() - Method in class com.swiftmq.impl.mqtt.MQTTSwiftlet
 
getSMQRFactory() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getSndSettleMode() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
getSourceLink() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.Delivery
 
getSourceLink() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceMessageProcessor
 
getSourceMessageProcessor() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.po.POSendMessages
 
getSourceMessageProcessor() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSendMessages
 
getStage() - Method in class com.swiftmq.impl.routing.single.connection.stage.StageQueue
 
getStageQueue() - Method in class com.swiftmq.impl.routing.single.connection.stage.Stage
 
getStartQueueSize() - Method in class com.swiftmq.impl.queue.standard.queue.FlowControllerImpl
 
getStartTime() - Method in class com.swiftmq.impl.scheduler.standard.po.JobStart
 
getStartTimeSec() - Method in class com.swiftmq.impl.scheduler.standard.po.JobStart
 
getStaticQueue(String) - Method in class com.swiftmq.impl.jndi.standard.JNDISwiftletImpl
 
getStoreEntries() - Method in class com.swiftmq.impl.store.standard.PersistentStoreImpl
 
getStoreEntry() - Method in class com.swiftmq.impl.mqtt.pubsub.Subscription
 
getStoreTime(int) - Method in class com.swiftmq.impl.streams.comp.memory.HeapMemory
 
getStoreTime(int) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Internal use.
getStoreTime(int) - Method in class com.swiftmq.impl.streams.comp.memory.QueueMemory
 
getStoreTime(Message) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
 
getStoreTimes() - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Internal use.
getStreamCtx() - Method in class com.swiftmq.impl.streams.Stream
Internal use
getSubscriberId() - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
Internal use.
getSubscriberId() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
getSubscriberQueueName() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
getSubscription() - Method in class com.swiftmq.impl.mqtt.po.POSendMessage
 
getSupportedOutcomes() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
getSupportedVersions() - Static method in class com.swiftmq.impl.topic.standard.announce.TopicInfoFactory
 
getTargetLink() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.po.POSendFlow
 
getTempQueues() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
getTimeExpression() - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
getTimeOfTheDay(Calendar) - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
getTimer() - Method in class com.swiftmq.impl.streams.processor.po.POTimer
 
getTimerListener() - Method in class com.swiftmq.impl.streams.comp.timer.AtTimer
 
getTimerListener() - Method in class com.swiftmq.impl.streams.comp.timer.IntervalTimer
 
getTimerListener() - Method in class com.swiftmq.impl.streams.comp.timer.NextTimer
 
getTimerListener() - Method in interface com.swiftmq.impl.streams.comp.timer.Timer
Internal use.
getTimers() - Method in class com.swiftmq.impl.streams.Stream
Internal use only
getTokenizedName() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
getTokenizedPredicate() - Method in interface com.swiftmq.impl.topic.standard.announce.TopicInfo
 
getTokenizedPredicate() - Method in class com.swiftmq.impl.topic.standard.announce.v400.TopicInfoImpl
 
getTopicDelimiter() - Method in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
getTopicInfo() - Method in class com.swiftmq.impl.topic.standard.announce.po.POAnnounceSubscriptions
 
getTopicName() - Method in class com.swiftmq.impl.mqtt.po.POSendMessage
 
getTopicName() - Method in class com.swiftmq.impl.mqtt.pubsub.Subscription
 
getTopicName() - Method in class com.swiftmq.impl.topic.standard.announce.po.POSubscriptionAdded
 
getTopicName() - Method in class com.swiftmq.impl.topic.standard.announce.po.POSubscriptionRemoved
 
getTopicName() - Method in class com.swiftmq.impl.topic.standard.announce.po.POTopicCreated
 
getTopicName() - Method in class com.swiftmq.impl.topic.standard.announce.po.POTopicRemoved
 
getTopicName() - Method in interface com.swiftmq.impl.topic.standard.announce.TopicInfo
 
getTopicName() - Method in class com.swiftmq.impl.topic.standard.announce.v400.TopicInfoImpl
 
getTopicName() - Method in class com.swiftmq.impl.topic.standard.DurableSubscription
 
getTopicName() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
getTopicName(String[]) - Method in class com.swiftmq.impl.topic.standard.TopicBroker
 
getTopicNames() - Method in class com.swiftmq.impl.topic.standard.TopicBroker
 
getTopicNames() - Method in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
getTopicQueuePrefix() - Method in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
getTopicSubscriberTransaction(int) - Method in class com.swiftmq.impl.topic.standard.TopicTransaction
 
getTopicSubscription() - Method in class com.swiftmq.impl.topic.standard.DurableSubscription
 
getTopicSubscription() - Method in class com.swiftmq.impl.topic.standard.TopicSubscriberTransaction
 
getTotalMsgsReceived() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler
 
getTotalMsgsReceived() - Method in class com.swiftmq.impl.jms.standard.v750.SessionContext
 
getTotalMsgsReceived() - Method in class com.swiftmq.impl.mqtt.pubsub.Subscription
 
getTotalMsgsReceived() - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
getTotalMsgsSent() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler
 
getTotalMsgsSent() - Method in class com.swiftmq.impl.jms.standard.v750.SessionContext
 
getTotalMsgsSent() - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
getTraceKey() - Method in interface com.swiftmq.impl.amqp.OutboundTracer
 
getTraceString(Object) - Method in interface com.swiftmq.impl.amqp.OutboundTracer
 
getTransaction() - Method in class com.swiftmq.impl.jms.standard.v750.Consumer
 
getTransaction() - Method in class com.swiftmq.impl.jms.standard.v750.Producer
 
getTransaction() - Method in class com.swiftmq.impl.mqtt.po.POSendMessage
 
getTransaction() - Method in class com.swiftmq.impl.streams.processor.QueueMessageProcessor
 
getTransaction() - Method in class com.swiftmq.impl.topic.standard.TopicSubscriberTransaction
 
getTransactionId() - Method in class com.swiftmq.impl.topic.standard.TopicTransaction
 
getTransactionList(int) - Method in class com.swiftmq.impl.queue.standard.queue.ActiveTransactionRegistry
 
getTransactionRegistry() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler
 
getTransactionSize() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getTransactionSize() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.AdjustRequest
 
getTransactionSize() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.AdjustRequest
 
getTransactionTimeout() - Method in class com.swiftmq.impl.xa.standard.XAResourceManagerSwiftletImpl
 
getTransactionType() - Method in class com.swiftmq.impl.queue.standard.queue.TransactionId
 
getTransformedMessage() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceMessageProcessor
 
getTransformedMessages() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.SourceMessageProcessor
 
getTransformedMessages() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceMessageProcessor
 
getTransformer() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
getTxId() - Method in class com.swiftmq.impl.queue.standard.queue.TransactionId
 
getTxId() - Method in class com.swiftmq.impl.store.standard.log.LogRecord
 
getTxidCount() - Method in class com.swiftmq.impl.store.standard.transaction.TransactionManager
 
getTxList() - Method in class com.swiftmq.impl.queue.standard.queue.TransactionId
 
getType() - Method in interface com.swiftmq.impl.amqp.amqp.v00_09_01.Exchange
 
getType() - Method in interface com.swiftmq.impl.routing.single.route.Route
 
getType() - Method in class com.swiftmq.impl.routing.single.route.v400.RouteImpl
 
getType() - Method in class com.swiftmq.impl.store.standard.log.DeleteLogAction
 
getType() - Method in class com.swiftmq.impl.store.standard.log.InsertLogAction
 
getType() - Method in class com.swiftmq.impl.store.standard.log.LogAction
 
getType() - Method in class com.swiftmq.impl.store.standard.log.UpdateLogAction
 
getType() - Method in class com.swiftmq.impl.store.standard.log.UpdatePortionLogAction
 
getType() - Method in class com.swiftmq.impl.store.standard.xa.PrepareLogRecordImpl
 
getType() - Method in class com.swiftmq.impl.streams.comp.io.Output
 
getType() - Method in class com.swiftmq.impl.streams.comp.io.QueueOutput
 
getType() - Method in class com.swiftmq.impl.streams.comp.io.TopicOutput
 
getUsage() - Method in class com.swiftmq.impl.amqp.VersionedConnection
 
getUsage() - Method in class com.swiftmq.impl.mqtt.connection.MQTTConnection
 
getUserName() - Method in class com.swiftmq.impl.auth.standard.LoginId
 
getUserName() - Method in class com.swiftmq.impl.jms.standard.v750.JMSConnection
 
getUserName() - Method in class com.swiftmq.impl.mgmt.standard.po.ClientRequest
 
getValue() - Method in class com.swiftmq.impl.mgmt.standard.po.PropertyChanged
 
getValue(String, String) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.transformer.InboundTransformer
 
getValue(String, String) - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.transformer.OutboundTransformer
 
getValue(String, String) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.InboundTransformer
 
getValue(String, String) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.OutboundTransformer
 
getVersion() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandler
 
getVersion() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.AMQPHandler
 
getVersion() - Method in interface com.swiftmq.impl.amqp.Handler
 
getVersion() - Method in class com.swiftmq.impl.amqp.sasl.v01_00_00.SASLHandler
 
getVersion() - Method in interface com.swiftmq.impl.routing.single.route.Route
 
getVersion() - Method in class com.swiftmq.impl.routing.single.route.v400.RouteImpl
 
getVersionedConnection() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandler
 
getVersionedConnection() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.ChannelHandler
 
getVersionedConnection() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler
 
getVersionNotification() - Method in class com.swiftmq.impl.topic.standard.announce.po.POVersionNoteReceived
 
getViewContent() - Method in class com.swiftmq.impl.queue.standard.queue.View
 
getViewId() - Method in class com.swiftmq.impl.queue.standard.queue.View
 
getVisitor() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getWaitingPO() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
getWatchListener() - Method in class com.swiftmq.impl.queue.standard.queue.ActiveQueueImpl
 
getWindowSize() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
getWindowSize() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.AdjustRequest
 
getWindowSize() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.AdjustRequest
 
getWireTapInput() - Method in class com.swiftmq.impl.streams.processor.po.POWireTapMessage
 
getWorkingDirectory() - Method in class com.swiftmq.impl.streams.Stream
Returns the working directory of the router
getXAContext(XidImpl) - Method in class com.swiftmq.impl.xa.standard.XAResourceManagerSwiftletImpl
 
getXid() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.CommitReplyRequest
 
getXid() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.CommitRequest
 
getXid() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RollbackReplyRequest
 
getXid() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RollbackRequest
 
getXid() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.TransactionRequest
 
getXid() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.CommitReplyRequest
 
getXid() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.CommitRequest
 
getXid() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RollbackReplyRequest
 
getXid() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RollbackRequest
 
getXid() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.TransactionRequest
 
getXid() - Method in class com.swiftmq.impl.xa.standard.XAContextImpl
 
getXidList() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.RecoveryReplyRequest
 
getXidList() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.RecoveryReplyRequest
 
getXids() - Method in class com.swiftmq.impl.xa.standard.HeuristicHandler
 
getZombiConnectionTimeout() - Method in class com.swiftmq.impl.net.netty.NetworkSwiftletImpl
 
GraalSetup - Class in com.swiftmq.impl.streams.graalvm
 
GraalSetup() - Constructor for class com.swiftmq.impl.streams.graalvm.GraalSetup
 
grantedQoSLevels() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttSubAckPayload
 
group(String) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Groups all Messages over a Property and returns a Group Result.
Group - Class in com.swiftmq.impl.auth.standard
 
Group - Class in com.swiftmq.impl.threadpool.standard.group
 
Group(String) - Constructor for class com.swiftmq.impl.auth.standard.Group
 
Group(String, boolean) - Constructor for class com.swiftmq.impl.threadpool.standard.group.Group
 
GroupInactivityTimeout - Class in com.swiftmq.impl.streams.comp.memory
A GroupInactivityTimeout can be attached to a MemoryGroup and specifies a time of inactivity (no adds to attached Memory) after which all Messages in that Memory will retire and the Memory will be closed and removed from the MemoryGroup.
groupPropertyName() - Method in class com.swiftmq.impl.streams.comp.memory.MemoryGroup
Returns the name of the group Property.
GroupRegistry - Class in com.swiftmq.impl.threadpool.standard.group
 
GroupRegistry(SwiftletContext) - Constructor for class com.swiftmq.impl.threadpool.standard.group.GroupRegistry
 
GroupResult - Class in com.swiftmq.impl.streams.comp.memory
Represents the result of a group operation on a Memory.

H

Handler - Interface in com.swiftmq.impl.amqp
 
handleRequest(Request) - Method in class com.swiftmq.impl.routing.single.smqpr.SMQRVisitor
 
HandlerFactory - Interface in com.swiftmq.impl.amqp
 
hasAddCallback() - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
Internal use
hasCalendarRef(String, Map) - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
hasCalendarRef(String, Map) - Method in class com.swiftmq.impl.scheduler.standard.SchedulerCalendar
 
hasChangeCallback() - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
Internal use
hasChanged(String, Selector, boolean) - Method in class com.swiftmq.impl.topic.standard.DurableSubscription
 
hashCode() - Method in class com.swiftmq.impl.mqtt.v311.netty.util.AbstractConstant
 
hashCode() - Method in error com.swiftmq.impl.mqtt.v311.netty.util.Signal
 
hashCode() - Method in record class com.swiftmq.impl.queue.standard.queue.PropertyWatchManager.PropertyWatchEntry
Returns a hash code value for this object.
hashCode() - Method in class com.swiftmq.impl.streams.AsyncProxy
 
hasHeuristic(XidImpl) - Method in class com.swiftmq.impl.xa.standard.HeuristicHandler
 
hasHop(String) - Method in interface com.swiftmq.impl.routing.single.route.Route
 
hasHop(String) - Method in class com.swiftmq.impl.routing.single.route.v400.RouteImpl
 
hasInterestedProcessor(MessageImpl) - Method in class com.swiftmq.impl.queue.standard.queue.MessageProcessorRegistry
 
hasJobFactory(String) - Method in class com.swiftmq.impl.scheduler.standard.JobGroupImpl
 
hasListener - Variable in class com.swiftmq.impl.jms.standard.v750.Consumer
 
hasListener() - Method in class com.swiftmq.impl.jms.standard.v750.Consumer
 
hasNext() - Method in class com.swiftmq.impl.store.standard.DurableSubscriberStoreImpl
 
hasNext() - Method in class com.swiftmq.impl.store.standard.index.IndexPage
 
hasPassword() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnectVariableHeader
 
hasPassword(boolean) - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageBuilders.ConnectBuilder
 
hasPreparedXid(XidImpl) - Method in class com.swiftmq.impl.xa.standard.XAResourceManagerSwiftletImpl
 
hasReceiver() - Method in interface com.swiftmq.impl.queue.standard.cluster.QueueMetric
 
hasReceiver() - Method in class com.swiftmq.impl.queue.standard.cluster.v700.QueueMetricImpl
 
hasReceiver(MessageImpl) - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredQueue
 
hasReceiver(MessageImpl) - Method in class com.swiftmq.impl.queue.standard.composite.CompositeQueue
 
hasReceiver(MessageImpl) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
hasReceiver(MessageImpl) - Method in class com.swiftmq.impl.topic.standard.TopicBroker
 
hasRemoveCallback() - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
Internal use
hasSpace() - Method in interface com.swiftmq.impl.store.standard.swap.SwapFile
 
hasSpace() - Method in class com.swiftmq.impl.store.standard.swap.SwapFileImpl
 
hasUser(boolean) - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttMessageBuilders.ConnectBuilder
 
hasUserName() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnectVariableHeader
 
HEADER_LENGTH - Static variable in class com.swiftmq.impl.store.standard.cache.Page
 
heap() - Method in class com.swiftmq.impl.streams.comp.memory.MemoryBuilder
Creates a Memory that stores Messages on the Heap
HeapMemory - Class in com.swiftmq.impl.streams.comp.memory
Memory implementation that stores all Messages on the heap.
HeapMemory(StreamContext) - Constructor for class com.swiftmq.impl.streams.comp.memory.HeapMemory
 
heuristicHandler - Variable in class com.swiftmq.impl.xa.standard.SwiftletContext
 
HeuristicHandler - Class in com.swiftmq.impl.xa.standard
 
HeuristicHandler(SwiftletContext) - Constructor for class com.swiftmq.impl.xa.standard.HeuristicHandler
 
heuristicUsageList - Variable in class com.swiftmq.impl.xa.standard.SwiftletContext
 
hour() - Method in class com.swiftmq.impl.streams.TimeSupport
Returns the hour of the current time.
hour(long, int) - Method in class com.swiftmq.impl.streams.TimeSupport
Returns the hour from the time+offset.
hours(int) - Method in class com.swiftmq.impl.streams.comp.memory.GroupInactivityTimeout
Adds n hours to the timeout.
hours(int) - Method in class com.swiftmq.impl.streams.comp.memory.InactivityTimeout
Adds n hours to the timeout.
hours(int) - Method in class com.swiftmq.impl.streams.comp.memory.limit.TimeLimit
Adds n hours to the limit.
hours(int) - Method in class com.swiftmq.impl.streams.comp.memory.limit.TimeUnitChangeLimit
Sets a hours time unit limit
hours(int) - Method in class com.swiftmq.impl.streams.comp.timer.IntervalTimer
Adds n hours to the interval.

I

id() - Method in class com.swiftmq.impl.mqtt.v311.netty.util.AbstractConstant
 
id() - Method in interface com.swiftmq.impl.mqtt.v311.netty.util.Constant
Returns the unique number assigned to this Constant.
id() - Method in error com.swiftmq.impl.mqtt.v311.netty.util.Signal
 
Importer - Class in com.swiftmq.impl.queue.standard.command
 
Importer(SwiftletContext) - Constructor for class com.swiftmq.impl.queue.standard.command.Importer
 
inactivityTimeout() - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Sets and returns the InactivityTimeout for this Memory.
inactivityTimeout() - Method in class com.swiftmq.impl.streams.comp.memory.MemoryGroup
Sets and returns the GroupInactivityTimeout for this Memory.
InactivityTimeout - Class in com.swiftmq.impl.streams.comp.memory
InactivityTimeout can be attached to a Memory and specifies a time of inactivity (no adds to Memory) after which all Messages in that Memory will retire.
inboundFCEnabled - Variable in class com.swiftmq.impl.routing.single.SwiftletContext
 
inboundReader - Variable in class com.swiftmq.impl.jms.standard.v750.JMSConnection
 
InboundReader - Class in com.swiftmq.impl.jms.standard.v750
 
InboundReader - Class in com.swiftmq.impl.routing.single.connection
 
InboundTransformer - Class in com.swiftmq.impl.amqp.amqp.v00_09_01.transformer
 
InboundTransformer - Class in com.swiftmq.impl.amqp.amqp.v01_00_00.transformer
 
InboundTransformer() - Constructor for class com.swiftmq.impl.amqp.amqp.v00_09_01.transformer.InboundTransformer
 
InboundTransformer() - Constructor for class com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.InboundTransformer
 
incCount() - Static method in class com.swiftmq.impl.xa.standard.XAContextImpl
 
incDeliveryCount(QueueIndexEntry) - Method in class com.swiftmq.impl.store.standard.index.QueueIndex
 
incDeliveryCountSnd() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
include(String) - Method in class com.swiftmq.impl.streams.comp.io.ManagementInput
Adds Property name(s) that must be addionally included in an onChange message.
incMsgsReceived(int) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler
 
incMsgsReceived(int) - Method in class com.swiftmq.impl.jms.standard.v750.SessionContext
 
incMsgsSent(int) - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler
 
incMsgsSent(int) - Method in class com.swiftmq.impl.jms.standard.v750.SessionContext
 
incNumberConnections() - Method in class com.swiftmq.impl.auth.standard.User
 
increaseActiveTransactions() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
increaseActiveTransactions() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
increaseActiveTransactions() - Method in interface com.swiftmq.impl.amqp.amqp.v01_00_00.transaction.ResourceProvider
 
incRefCount() - Method in class com.swiftmq.impl.store.standard.index.MessagePageReference
 
incrementConsumed() - Method in class com.swiftmq.impl.queue.standard.queue.QueueMetrics
 
incrementProduced() - Method in class com.swiftmq.impl.queue.standard.queue.QueueMetrics
 
index(String) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Returns the Index of the specific Property name
Index - Class in com.swiftmq.impl.store.standard.index
 
Index - Class in com.swiftmq.impl.streams.comp.memory
Property Index that helds Property Values and References to Messages.
Index(StoreContext, int) - Constructor for class com.swiftmq.impl.store.standard.index.Index
 
IndexAnalyzer - Class in com.swiftmq.impl.store.standard.index
 
IndexAnalyzer(StoreContext) - Constructor for class com.swiftmq.impl.store.standard.index.IndexAnalyzer
 
IndexEntry - Class in com.swiftmq.impl.store.standard.index
 
IndexEntry() - Constructor for class com.swiftmq.impl.store.standard.index.IndexEntry
 
IndexPage - Class in com.swiftmq.impl.store.standard.index
 
IndexPage(StoreContext, int) - Constructor for class com.swiftmq.impl.store.standard.index.IndexPage
 
info(String) - Method in class com.swiftmq.impl.streams.comp.log.Log
Write an informational message to the log file.
init() - Method in class com.swiftmq.impl.routing.single.connection.stage.ProtocolSelectStage
 
init() - Method in class com.swiftmq.impl.routing.single.connection.stage.Stage
 
init() - Method in class com.swiftmq.impl.routing.single.connection.v942.AuthStage
 
init() - Method in class com.swiftmq.impl.routing.single.connection.v942.ConnectStage
 
init() - Method in class com.swiftmq.impl.routing.single.connection.v942.NonXADeliveryStage
 
init() - Method in class com.swiftmq.impl.routing.single.connection.v942.XADeliveryStage
 
init() - Method in class com.swiftmq.impl.routing.single.connection.v942.XARecoveryStage
 
init() - Method in class com.swiftmq.impl.streams.StreamController
 
init(long) - Method in class com.swiftmq.impl.store.standard.log.AppendLogFile
 
init(long) - Method in interface com.swiftmq.impl.store.standard.log.LogFile
 
init(long) - Method in class com.swiftmq.impl.store.standard.log.ReuseLogFile
 
init(Entity) - Static method in class com.swiftmq.impl.store.standard.pagedb.PageSize
 
initCause(Throwable) - Method in error com.swiftmq.impl.mqtt.v311.netty.util.Signal
 
initialPages - Variable in class com.swiftmq.impl.store.standard.cache.StableStore
 
initiateCheckPoint(CheckPointFinishedListener) - Method in class com.swiftmq.impl.store.standard.transaction.TransactionManager
 
initiateClose(String) - Method in class com.swiftmq.impl.mqtt.connection.MQTTConnection
 
InitiateSyncOperation - Class in com.swiftmq.impl.store.standard.log
 
InitiateSyncOperation() - Constructor for class com.swiftmq.impl.store.standard.log.InitiateSyncOperation
 
initLogFile() - Method in interface com.swiftmq.impl.store.standard.log.LogManager
 
initLogFile() - Method in class com.swiftmq.impl.store.standard.log.LogManagerEventProcessor
 
input(TempQueue) - Method in class com.swiftmq.impl.streams.Stream
Returns the Input for this TempQueue.
input(TempQueue) - Method in class com.swiftmq.impl.streams.StreamBuilder
Returns a new InputBuilder
input(String) - Method in class com.swiftmq.impl.streams.Stream
Returns the Input with the given name.
input(String) - Method in class com.swiftmq.impl.streams.StreamBuilder
Returns a new InputBuilder
Input - Interface in com.swiftmq.impl.streams.comp.io
Base interface for Inputs.
InputBuilder - Class in com.swiftmq.impl.streams.comp.io
Factory to create Inputs.
InputBuilder(StreamContext, String) - Constructor for class com.swiftmq.impl.streams.comp.io.InputBuilder
Internal use.
InputCallback - Interface in com.swiftmq.impl.streams.comp.io
Callback that can be registered on an Input (onInput).
insert(StoreEntry) - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
insert(StoreEntry) - Method in class com.swiftmq.impl.store.standard.NonPersistentStoreImpl
 
insert(StoreEntry) - Method in class com.swiftmq.impl.store.standard.StoreWriteTransactionImpl
 
INSERT - Static variable in class com.swiftmq.impl.store.standard.log.LogAction
 
insertDuplicateBacklog(String, StoreId) - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
insertDurableStoreEntry(DurableStoreEntry) - Method in class com.swiftmq.impl.store.standard.DurableSubscriberStoreImpl
 
InsertLogAction - Class in com.swiftmq.impl.store.standard.log
 
InsertLogAction(int) - Constructor for class com.swiftmq.impl.store.standard.log.InsertLogAction
 
INSTANCE - Static variable in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttEncoder
 
INTERNAL_QUEUE - Static variable in class com.swiftmq.impl.scheduler.standard.SwiftletContext
 
internalClose() - Method in class com.swiftmq.impl.threadpool.standard.group.EventLoopImpl
 
interval() - Method in class com.swiftmq.impl.streams.comp.timer.TimerBuilder
Creates an IntervalTimer.
IntervalTimer - Class in com.swiftmq.impl.streams.comp.timer
Interval Timer implementation.
IntraVMScheduler - Class in com.swiftmq.impl.net.netty.scheduler
 
IntraVMScheduler(SwiftletContext) - Constructor for class com.swiftmq.impl.net.netty.scheduler.IntraVMScheduler
 
IntraVMServerEndpointImpl - Class in com.swiftmq.impl.net.netty.scheduler
 
IntraVMServerEndpointImpl(SwiftletContext, IntraVMConnection) - Constructor for class com.swiftmq.impl.net.netty.scheduler.IntraVMServerEndpointImpl
 
intValue(Integer, int) - Static method in class com.swiftmq.impl.mqtt.v311.netty.util.internal.ObjectUtil
Resolves a possibly null Integer to a primitive int, using a default value.
InvalidToUnderscoreNameTranslator - Class in com.swiftmq.impl.amqp.amqp.v01_00_00.transformer
 
InvalidToUnderscoreNameTranslator() - Constructor for class com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.InvalidToUnderscoreNameTranslator
 
InvalidTransactionId - Exception in com.swiftmq.impl.amqp.amqp.v01_00_00.transaction
 
InvalidTransactionId(String) - Constructor for exception com.swiftmq.impl.amqp.amqp.v01_00_00.transaction.InvalidTransactionId
 
invoke(Object, Method, Object[]) - Method in class com.swiftmq.impl.streams.AsyncProxy
 
invoke(String, Object[], String[]) - Method in class com.swiftmq.impl.mgmt.standard.jmx.EntityMBean
 
ioScheduler - Variable in class com.swiftmq.impl.net.netty.NetworkSwiftletImpl
 
IOScheduler - Class in com.swiftmq.impl.net.netty.scheduler
 
IOScheduler(SwiftletContext) - Constructor for class com.swiftmq.impl.net.netty.scheduler.IOScheduler
 
isActive() - Method in class com.swiftmq.impl.net.netty.scheduler.NettyOutboundConnectionHandler
 
isActive() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
isActive() - Method in class com.swiftmq.impl.routing.single.RouteImpl
 
isAnnounced() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
isAnnounceEnabled(String, String) - Method in class com.swiftmq.impl.topic.standard.announce.AnnounceFilters
 
isApacheSelectors() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.AMQPHandler
 
isApplySystemTimeChange() - Method in class com.swiftmq.impl.scheduler.standard.AtSchedule
 
isApplySystemTimeChange() - Method in class com.swiftmq.impl.scheduler.standard.RepeatSchedule
 
isApplySystemTimeChange() - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
isAssociated() - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
isAuthRequired() - Method in class com.swiftmq.impl.routing.single.smqpr.v400.ConnectReplyRequest
 
isAuthRequired() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectReplyRequest
 
isAutoCommit() - Method in class com.swiftmq.impl.jms.standard.v750.Consumer
 
isAutoCommit() - Method in class com.swiftmq.impl.jms.standard.v750.TopicConsumer
 
isBrowserGranted() - Method in class com.swiftmq.impl.auth.standard.QueueResourceGrant
 
isBulkMode(String) - Method in class com.swiftmq.impl.threadpool.standard.group.GroupRegistry
 
isCheckPointActive() - Method in class com.swiftmq.impl.store.standard.cache.StableStore
 
isCheckPointInProgress() - Method in class com.swiftmq.impl.store.standard.transaction.TransactionManager
 
isCleanSession() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnectVariableHeader
 
isClosed() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.Consumer
 
isClosed() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
isClosed() - Method in class com.swiftmq.impl.jms.standard.v750.JMSConnection
 
isClosed() - Method in class com.swiftmq.impl.jms.standard.v750.Session
 
isClosed() - Method in class com.swiftmq.impl.net.netty.scheduler.NettyInboundConnectionHandler
 
isClosed() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
isCommandGranted(Entity, String) - Method in class com.swiftmq.impl.mgmt.standard.auth.AuthenticatorImpl
 
isCompactOnStartup() - Static method in class com.swiftmq.impl.store.standard.pagedb.PageSize
 
isComplete() - Method in class com.swiftmq.impl.amqp.sasl.provider.AnonServer
 
isComplete() - Method in class com.swiftmq.impl.amqp.sasl.provider.PlainServer
 
isComplete() - Method in class com.swiftmq.impl.store.standard.log.LogRecord
 
isConnected() - Method in class com.swiftmq.impl.jndi.standard.JNDIReplication
 
isContextGranted(Entity) - Method in class com.swiftmq.impl.mgmt.standard.auth.AuthenticatorImpl
 
isContextGranted(String, boolean) - Method in class com.swiftmq.impl.mgmt.standard.auth.Role
 
isContextGrantedAndReadOnly(String) - Method in class com.swiftmq.impl.mgmt.standard.auth.Role
 
isConverted() - Method in class com.swiftmq.impl.store.standard.pagedb.StoreConverter
 
isCoordinator() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink
 
isCountDeliveredRequests() - Method in class com.swiftmq.impl.jms.standard.v750.Session
 
isCountDeliveredRequests() - Method in class com.swiftmq.impl.jms.standard.v750.TransactedSession
 
isCreateDurableGranted() - Method in class com.swiftmq.impl.auth.standard.TopicResourceGrant
 
isCreationInfo() - Method in interface com.swiftmq.impl.topic.standard.announce.TopicInfo
 
isCreationInfo() - Method in class com.swiftmq.impl.topic.standard.announce.v400.TopicInfoImpl
 
isDeliverExpired() - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
isDirectSubscriberSelection() - Method in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
isDirty() - Method in class com.swiftmq.impl.queue.standard.queue.View
 
isDirty() - Method in class com.swiftmq.impl.streams.comp.io.Output
Internal use.
isDisconnectDeleteDurable() - Method in class com.swiftmq.impl.topic.standard.SlowSubscriberCondition
 
isDisconnectNonDurable() - Method in class com.swiftmq.impl.topic.standard.SlowSubscriberCondition
 
isDnsResolve() - Method in class com.swiftmq.impl.net.netty.NetworkSwiftletImpl
 
isDrain() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
isDup() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttFixedHeader
 
isDurable() - Method in class com.swiftmq.impl.streams.comp.io.TopicInput
Internal use.
isDurable() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
isDurableGranted(String) - Method in class com.swiftmq.impl.streams.StreamsSwiftlet
 
isDynamic() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink
 
isEnabled() - Method in class com.swiftmq.impl.jndi.standard.JNDIReplication
 
isEnabled() - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
isExpired() - Method in interface com.swiftmq.impl.mgmt.standard.Dispatcher
 
isExpired() - Method in class com.swiftmq.impl.mgmt.standard.v750.DispatcherImpl
 
isFailure() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.DecoderResult
 
isFinished() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.DecoderResult
 
isFlowAfterDrainRequired() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
isForceCopy() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
isForceSync() - Method in interface com.swiftmq.impl.store.standard.log.LogManager
 
isForceSync() - Method in class com.swiftmq.impl.store.standard.log.LogManagerEventProcessor
 
isFreezable() - Method in class com.swiftmq.impl.threadpool.standard.group.Group
 
isHeuristicCommit(XidImpl) - Method in class com.swiftmq.impl.xa.standard.XAResourceManagerSwiftletImpl
 
isHeuristicCompleted(XidImpl) - Method in class com.swiftmq.impl.xa.standard.XAResourceManagerSwiftletImpl
 
isHeuristicRollback(XidImpl) - Method in class com.swiftmq.impl.xa.standard.XAResourceManagerSwiftletImpl
 
isHostAllowed(String) - Method in class com.swiftmq.impl.auth.standard.User
 
isInDateRange(long) - Method in class com.swiftmq.impl.scheduler.standard.ScheduleEntry
 
isInMemoryMode() - Method in class com.swiftmq.impl.store.standard.log.AppendLogFile
 
isInMemoryMode() - Method in interface com.swiftmq.impl.store.standard.log.LogFile
 
isInMemoryMode() - Method in class com.swiftmq.impl.store.standard.log.ReuseLogFile
 
isInvalid() - Method in interface com.swiftmq.impl.mgmt.standard.Dispatcher
 
isInvalid() - Method in class com.swiftmq.impl.mgmt.standard.v750.DispatcherImpl
 
isKeepOnUnsubscribe() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
isLate(Message) - Method in class com.swiftmq.impl.streams.comp.memory.Memory
 
isLicenseLimit() - Method in class com.swiftmq.impl.routing.single.manager.ConnectionManager
 
isLicenseLimit() - Method in class com.swiftmq.impl.routing.unlimited.UConnectionManager
 
isListener() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
isLocked() - Method in class com.swiftmq.impl.queue.standard.queue.StoreId
 
isLogDuplicates() - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
isLogExpired() - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
isLoggingEnabled() - Method in class com.swiftmq.impl.scheduler.standard.Schedule
 
isMarkedAsClose() - Method in class com.swiftmq.impl.streams.comp.memory.Memory
Internal use.
isMarkedAsClose() - Method in class com.swiftmq.impl.streams.comp.memory.MemoryGroup
Internal Use.
isMarkedForClose() - Method in class com.swiftmq.impl.jms.standard.v750.Consumer
 
isMarkedForClose() - Method in class com.swiftmq.impl.jms.standard.v750.Producer
 
isMarkedForClose() - Method in interface com.swiftmq.impl.jms.standard.v750.TransactionFactory
 
isMatch(int, TopicSubscription) - Method in class com.swiftmq.impl.topic.standard.SlowSubscriberCondition
 
isMessageBasedDispatch() - Method in class com.swiftmq.impl.queue.standard.cluster.ClusteredTransactionId
 
isMessageBasedDispatch() - Method in interface com.swiftmq.impl.queue.standard.cluster.DispatchPolicy
 
isMessageBasedDispatch() - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
isMessageBasedDispatch() - Method in class com.swiftmq.impl.queue.standard.cluster.RoundRobinDispatchPolicy
 
isMessageProcessorRunning() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink
 
isMessageSchedule() - Method in class com.swiftmq.impl.scheduler.standard.po.ScheduleAdded
 
isMessageSchedule() - Method in class com.swiftmq.impl.scheduler.standard.po.ScheduleRemoved
 
isNoAck() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.Consumer
 
isNoLocal() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.Consumer
 
isNoLocal() - Method in class com.swiftmq.impl.topic.standard.DurableSubscription
 
isNoLocal() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
isNonpersistent() - Method in class com.swiftmq.impl.streams.comp.message.Message
Returns true if this Message is non-persistent.
isOnMessageEnabled() - Method in class com.swiftmq.impl.streams.comp.message.Message
Internal use.
isPersistent() - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
isPersistent() - Method in class com.swiftmq.impl.queue.standard.queue.StoreId
 
isPersistent() - Method in class com.swiftmq.impl.streams.comp.message.Message
Returns true if this Message is persistent.
isPersistentMessageIncluded() - Method in class com.swiftmq.impl.topic.standard.TopicSubscriberTransaction
 
isPrepared() - Method in class com.swiftmq.impl.xa.standard.XALiveContextImpl
 
isPrepared() - Method in class com.swiftmq.impl.xa.standard.XARecoveryContextImpl
 
isPropertyGranted(Entity, String) - Method in class com.swiftmq.impl.mgmt.standard.auth.AuthenticatorImpl
 
isPropertyReadOnly(Entity, String) - Method in class com.swiftmq.impl.mgmt.standard.auth.AuthenticatorImpl
 
isPublisherGranted() - Method in class com.swiftmq.impl.auth.standard.TopicResourceGrant
 
isQueueDefined(String) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
isQueueRunning(String) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
isReboot - Variable in class com.swiftmq.impl.deploy.standard.SwiftletContext
 
isReceiveGranted(String) - Method in class com.swiftmq.impl.streams.StreamsSwiftlet
 
isReceiverGranted() - Method in class com.swiftmq.impl.auth.standard.QueueResourceGrant
 
isReceiverSomewhere() - Method in interface com.swiftmq.impl.queue.standard.cluster.ClusteredQueueMetric
 
isReceiverSomewhere() - Method in interface com.swiftmq.impl.queue.standard.cluster.DispatchPolicy
 
isReceiverSomewhere() - Method in class com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy
 
isReceiverSomewhere() - Method in class com.swiftmq.impl.queue.standard.cluster.RoundRobinDispatchPolicy
 
isReceiverSomewhere() - Method in class com.swiftmq.impl.queue.standard.cluster.v700.ClusteredQueueMetricImpl
 
isRecovered() - Method in class com.swiftmq.impl.xa.standard.XAContextImpl
 
isRedelivered() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.Delivery
 
isRedispatch() - Method in interface com.swiftmq.impl.queue.standard.cluster.QueueMetric
 
isRedispatch() - Method in class com.swiftmq.impl.queue.standard.cluster.v700.QueueMetricImpl
 
isReferencable() - Method in class com.swiftmq.impl.store.standard.CompositeStoreTransactionImpl
 
isRemote() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
isRemovePending() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
isRequestXA() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectReplyRequest
 
isRequestXA() - Method in class com.swiftmq.impl.routing.single.smqpr.v942.ConnectRequest
 
isResizeOnStartup() - Static method in class com.swiftmq.impl.store.standard.pagedb.PageSize
 
isRetain() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttFixedHeader
 
isReuseServerSocket() - Method in class com.swiftmq.impl.net.netty.NetworkSwiftletImpl
 
isRunning() - Method in class com.swiftmq.impl.queue.standard.queue.MessageQueue
 
isRunning() - Method in class com.swiftmq.impl.topic.standard.TopicBroker
Returns if the queue is running or not
isSelected(MessageImpl) - Method in class com.swiftmq.impl.streams.comp.io.QueueWireTapInput
Internal use.
isSelected(MessageSelector) - Method in class com.swiftmq.impl.streams.comp.message.Message
Internal use only.
isSendable(Route) - Method in class com.swiftmq.impl.routing.single.route.RouteFilter
 
isSenderGranted() - Method in class com.swiftmq.impl.auth.standard.QueueResourceGrant
 
isSendExceptionEnabled() - Method in class com.swiftmq.impl.jms.standard.v750.InboundReader
 
isSendGranted(String) - Method in class com.swiftmq.impl.streams.StreamsSwiftlet
 
isSessionPresent() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnAckVariableHeader
 
isStarted() - Method in class com.swiftmq.impl.jms.standard.v750.AsyncMessageProcessor
 
isStaticRoute() - Method in class com.swiftmq.impl.routing.single.RouteImpl
 
isStaticSubscription() - Method in class com.swiftmq.impl.topic.standard.TopicSubscription
 
isSubscriberGranted() - Method in class com.swiftmq.impl.auth.standard.TopicResourceGrant
 
isSuccess() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.DecoderResult
 
isSystemQueue(String) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
isTemporaryQueue(String) - Method in class com.swiftmq.impl.queue.standard.QueueManagerImpl
 
isTopicDefined(String) - Method in class com.swiftmq.impl.topic.standard.TopicManagerImpl
 
isValid() - Method in class com.swiftmq.impl.amqp.amqp.v00_09_01.SourceMessageProcessor
 
isValid() - Method in class com.swiftmq.impl.amqp.amqp.v01_00_00.SourceMessageProcessor
 
isValid() - Method in class com.swiftmq.impl.jms.standard.v750.AsyncMessageProcessor
 
isValid() - Method in class com.swiftmq.impl.jndi.standard.QueueJNDIProcessor
 
isValid() - Method in class com.swiftmq.impl.jndi.standard.TopicJNDIProcessor
 
isValid() - Method in class com.swiftmq.impl.mgmt.standard.Listener
 
isValid() - Method in class com.swiftmq.impl.mgmt.standard.MessageInterfaceListener
 
isValid() - Method in class com.swiftmq.impl.mqtt.pubsub.Subscription
 
isValid() - Method in class com.swiftmq.impl.queue.standard.cluster.ClusterMetricSubscriber
 
isValid() - Method in class com.swiftmq.impl.queue.standard.cluster.Redispatcher
 
isValid() - Method in class com.swiftmq.impl.store.standard.index.IndexEntry
 
isValid() - Method in class com.swiftmq.impl.store.standard.xa.PrepareLogRecordImpl
 
isValid() - Method in class com.swiftmq.impl.streams.processor.QueueMessageProcessor
 
isValid() - Method in class com.swiftmq.impl.streams.StreamLibDeployer
 
isValid() - Method in class com.swiftmq.impl.topic.standard.announce.TopicAnnounceReceiver
 
isValid(Date, Map) - Method in class com.swiftmq.impl.scheduler.standard.SchedulerCalendar
 
isWasPresent() - Method in class com.swiftmq.impl.mqtt.session.MQTTSession
 
isWillFlag() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnectVariableHeader
 
isWillRetain() - Method in class com.swiftmq.impl.mqtt.v311.netty.handler.codec.mqtt.MqttConnectVariableHeader
 
isXa() - Method in class com.swiftmq.impl.routing.single.connection.RoutingConnection
 
iterateRootIndex(StoreConverter.QIEProcessor) - Method in class com.swiftmq.impl.store.standard.pagedb.StoreConverter
 
iterator() - Method in class com.swiftmq.impl.store.standard.DurableSubscriberStoreImpl
 
iterator() - Method in class com.swiftmq.impl.store.standard.index.IndexPage
 
ivmScheduler - Variable in class com.swiftmq.impl.net.netty.NetworkSwiftletImpl
 

J

jdbcLookup(String) - Method in class com.swiftmq.impl.streams.Stream
Returns the JDBCLookup with the given name.
jdbcLookup(String) - Method in class com.swiftmq.impl.streams.StreamBuilder
Returns a new JDBCLookup
JDBCLookup - Class in com.swiftmq.impl.streams.comp.jdbc
Facade to perform queries on a JDBC connected database.
JDBCLookup(StreamContext, String) - Constructor for class com.swiftmq.impl.streams.comp.jdbc.JDBCLookup
Interval use.
JMSConnection - Class in com.swiftmq.impl.jms.standard.v750
 
JMSConnection(SwiftletContext, Entity, Connection) - Constructor for class com.swiftmq.impl.jms.standard.v750.JMSConnection
 
JMSMappingInboundTransformer - Class in com.swiftmq.impl.amqp.amqp.v01_00_00.transformer
 
JMSMappingInboundTransformer() - Constructor for class com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.JMSMappingInboundTransformer
 
JMSMappingOutboundTransformer - Class in com.swiftmq.impl.amqp.amqp.v01_00_00.transformer
 
JMSMappingOutboundTransformer() - Constructor for class com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.JMSMappingOutboundTransformer
 
jmsSwiftlet - Variable in class com.swiftmq.impl.jms.standard.SwiftletContext
 
JMSSwiftlet - Class in com.swiftmq.impl.jms.standard
 
JMSSwiftlet() - Constructor for class com.swiftmq.impl.jms.standard.JMSSwiftlet
 
jmxUtil - Variable in class com.swiftmq.impl.mgmt.standard.SwiftletContext
 
JMXUtil - Class in com.swiftmq.impl.mgmt.standard.jmx
 
JMXUtil(SwiftletContext, boolean) - Constructor for class com.swiftmq.impl.mgmt.standard.jmx.JMXUtil
 
jndiAliasList - Variable in class com.swiftmq.impl.queue.standard.SwiftletContext
 
JNDIReplication - Class in com.swiftmq.impl.jndi.standard
 
JNDIReplication(SwiftletContext, String, boolean, long, String, String, String, EntityList) - Constructor for class com.swiftmq.impl.jndi.standard.JNDIReplication
 
jndiSwiftlet - Variable in class com.swiftmq.impl.jms.standard.SwiftletContext
 
jndiSwiftlet - Variable in class com.swiftmq.impl.jndi.standard.SwiftletContext
 
jndiSwiftlet - Variable in class com.swiftmq.impl.queue.standard.SwiftletContext
 
jndiSwiftlet - Variable in class com.swiftmq.impl.streams.SwiftletContext
 
jndiSwiftlet - Variable in class com.swiftmq.impl.topic.standard.TopicManagerContext
 
JNDISwiftletImpl - Class in com.swiftmq.impl.jndi.standard
 
JNDISwiftletImpl() - Constructor for class com.swiftmq.impl.jndi.standard.JNDISwiftletImpl
 
JobFactoryAdded - Class in com.swiftmq.impl.scheduler.standard.po
 
JobFactoryAdded(String, String, JobFactory) - Constructor for class com.swiftmq.impl.scheduler.standard.po.JobFactoryAdded
 
JobFactoryRemoved - Class in com.swiftmq.impl.scheduler.standard.po
 
JobFactoryRemoved(String, String) - Constructor for class com.swiftmq.impl.scheduler.standard.po.JobFactoryRemoved
 
JOBGROUP - Static variable in class com.swiftmq.impl.scheduler.standard.SwiftletContext
 
JobGroupImpl - Class in com.swiftmq.impl.scheduler.standard
 
JobGroupImpl(SwiftletContext, String, EntityList) - Constructor for class com.swiftmq.impl.scheduler.standard.JobGroupImpl
 
jobGroupList - Variable in class com.swiftmq.impl.scheduler.standard.SwiftletContext
 
JOBNAME - Static variable in class com.swiftmq.impl.scheduler.standard.SwiftletContext
 
JobRegistrar - Class in com.swiftmq.impl.queue.standard.jobs
 
JobRegistrar - Class in com.swiftmq.impl.routing.single.jobs
 
JobRegistrar - Class in com.swiftmq.impl.store.standard.jobs
 
JobRegistrar - Class in com.swiftmq.impl.streams.jobs
 
JobRegistrar - Class in com.swiftmq.impl.topic.standard.jobs
 
JobRegistrar(SwiftletContext) - Constructor for class com.swiftmq.impl.queue.standard.jobs.JobRegistrar
 
JobRegistrar(SwiftletContext) - Constructor for class com.swiftmq.impl.routing.single.jobs.JobRegistrar
 
JobRegistrar(StoreContext) - Constructor for class com.swiftmq.impl.store.standard.jobs.JobRegistrar
 
JobRegistrar(SwiftletContext) - Constructor for class com.swiftmq.impl.streams.jobs.JobRegistrar
 
JobRegistrar(TopicManagerImpl, SchedulerSwiftlet, TopicManagerContext) - Constructor for class com.swiftmq.impl.topic.standard.jobs.JobRegistrar
 
JobStart - Class in com.swiftmq.impl.scheduler.standard.po
 
JobStart(String, long, int, long) - Constructor for class com.swiftmq.impl.scheduler.standard.po.JobStart
 
JobStop - Class in com.swiftmq.impl.scheduler.standard.po
 
JobStop(String) - Constructor for class com.swiftmq.impl.scheduler.standard.po.JobStop
 
jobTerminated() - Method in class com.swiftmq.impl.queue.standard.jobs.MultiQueuePurgerJob
 
jobTerminated(String) - Method in class com.swiftmq.impl.queue.standard.jobs.MultiQueuePurgerJob
 
jobTerminated(JobException) - Method in class com.swiftmq.impl.queue.standard.jobs.MultiQueuePurgerJob
 
JobTerminated - Class in com.swi