public interface MessageSourceConsumer<X extends MessageSourceConsumer<X>> extends ConsumerImpl, Consumer<MessageSourceConsumer<X>>
ConsumerImpl.Option
CONSUMER_NUMBER_GENERATOR
DISTRIBUTION_MODE, EXCLUSIVE, NO_LOCAL, SELECTOR, SETTLEMENT_MODE, SUSPEND_NOTIFICATION_PERIOD, SUSPEND_NOTIFICATION_PERIOD_DEFAULT
CONTEXT, CREATED_BY, CREATED_TIME, DESCRIPTION, DESIRED_STATE, DURABLE, ID, LAST_UPDATED_BY, LAST_UPDATED_TIME, LIFETIME_POLICY, NAME, OVER_SIZED_ATTRIBUTE_ALTERNATIVE_TEXT, STATE, TYPE
acquires, close, externalStateChange, flush, getBytesOut, getConsumerNumber, getMessageSource, getMessagesOut, getName, getSendLock, getSessionModel, getTarget, getUnacknowledgedBytes, getUnacknowledgedMessages, isActive, isClosed, isSuspended, releaseSendLock, seesRequeues, trySendLock
getBytesOut, getDistributionMode, getMessagesOut, getSelector, getSettlementMode, getUnacknowledgedBytes, getUnacknowledgedMessages, isExclusive, isNoLocal
addChangeListener, asObjectRecord, close, closeAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, findConfiguredObject, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildExecutor, getChildren, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getLifetimePolicy, getModel, getName, getObjectFactory, getParent, getState, getStatistics, getTaskExecutor, getType, getTypeClass, isDurable, managesChildStorage, open, openAsync, removeChangeListener, setAttribute, setAttributes, setAttributesAsync
Copyright © 2006–2017 The Apache Software Foundation. All rights reserved.