public interface AddressControl
Modifier and Type | Field and Description |
---|---|
static String |
ADDRESS_SIZE_DESCRIPTION |
static String |
NUMBER_OF_PAGES_DESCRIPTION |
static String |
ROUTED_MESSAGE_COUNT_DESCRIPTION |
static String |
UNROUTED_MESSAGE_COUNT_DESCRIPTION |
Modifier and Type | Method and Description |
---|---|
boolean |
clearDuplicateIdCache() |
String |
getAddress()
Returns the managed address.
|
long |
getAddressSize()
Returns the number of estimated bytes being used by all the queue(s) bound to this address; used to control paging and blocking.
|
String[] |
getAllQueueNames()
Returns the names of both the local and remote queue(s) bound to this address.
|
String[] |
getBindingNames()
Returns the names of all bindings (both queues and diverts) bound to this address
|
long |
getCurrentDuplicateIdCacheSize() |
long |
getMessageCount() |
long |
getNumberOfBytesPerPage()
Returns the number of bytes used by each page for this address.
|
long |
getNumberOfMessages()
Returns the sum of messages on queue(s), including messages in delivery.
|
int |
getNumberOfPages()
Returns the number of pages used by this address.
|
String[] |
getQueueNames()
Returns the names of the local queue(s) bound to this address.
|
String[] |
getRemoteQueueNames()
Returns the names of the remote queue(s) bound to this address.
|
Object[] |
getRoles()
Returns the roles (name and permissions) associated with this address.
|
String |
getRolesAsJSON()
Returns the roles (name and permissions) associated with this address
using JSON serialization.
|
long |
getRoutedMessageCount()
Returns the number of messages routed to one or more bindings
|
String[] |
getRoutingTypes() |
String |
getRoutingTypesAsJSON() |
long |
getUnRoutedMessageCount()
Returns the number of messages not routed to any bindings
|
boolean |
isPaging()
Returns whether this address is paging.
|
boolean |
isPaused() |
boolean |
isRetroactiveResource() |
void |
pause()
Pauses all the queues bound to this address.Messages are no longer delivered to all its bounded queues.
|
void |
pause(boolean persist)
Pauses all the queues bound to this address.Messages are no longer delivered to all its bounded queues.Newly added queue will be paused too until resume is called.
|
void |
resume()
Resume all the queues bound of this address.Messages are delivered again to all its bounded queues.
|
String |
sendMessage(Map<String,String> headers,
int type,
String body,
boolean durable,
String user,
String password) |
static final String ROUTED_MESSAGE_COUNT_DESCRIPTION
static final String UNROUTED_MESSAGE_COUNT_DESCRIPTION
static final String ADDRESS_SIZE_DESCRIPTION
static final String NUMBER_OF_PAGES_DESCRIPTION
String getAddress()
String[] getRoutingTypes()
Object[] getRoles() throws Exception
Exception
String getRolesAsJSON() throws Exception
RoleInfo.from(String)
.Exception
long getAddressSize()
long getNumberOfMessages() throws Exception
Exception
String[] getRemoteQueueNames() throws Exception
Exception
String[] getQueueNames() throws Exception
Exception
String[] getAllQueueNames() throws Exception
Exception
int getNumberOfPages()
boolean isPaging() throws Exception
Exception
long getNumberOfBytesPerPage() throws Exception
Exception
String[] getBindingNames() throws Exception
Exception
long getMessageCount()
long getRoutedMessageCount()
long getUnRoutedMessageCount()
String sendMessage(Map<String,String> headers, int type, String body, boolean durable, String user, String password) throws Exception
headers
- the message headers and properties to set. Can only
container Strings maped to primitive types.body
- the text to senddurable
- user
- password
- @returnException
void pause() throws Exception
Exception
void pause(boolean persist) throws Exception
persist
- if true, the pause state will be persisted.Exception
void resume() throws Exception
Exception
boolean isPaused()
boolean isRetroactiveResource()
long getCurrentDuplicateIdCacheSize()
Copyright © 2021 JBoss by Red Hat. All rights reserved.