Index
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
Constant
s. - 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