public abstract class MessageQueueListener extends Object implements hudson.ExtensionPoint
コンストラクタと説明 |
---|
MessageQueueListener() |
修飾子とタイプ | メソッドと説明 |
---|---|
static hudson.ExtensionList<MessageQueueListener> |
all()
Gets all listeners.
|
static void |
fireOnBind(Collection<String> appIds,
String queueName)
Fires OnBind event.
|
static void |
fireOnReceive(String appId,
String queueName,
String contentType,
Map<String,Object> headers,
byte[] body)
Fires OnReceive event.
|
static void |
fireOnUnbind(Collection<String> appIds,
String queueName)
Fires OnUnbind event.
|
abstract String |
getAppId()
Gets application id.
|
abstract String |
getName()
Gets name.
|
abstract void |
onBind(String queueName)
Calls when binds to queue.
|
abstract void |
onReceive(String queueName,
String contentType,
Map<String,Object> headers,
byte[] body)
Calls when message arrives.
|
abstract void |
onUnbind(String queueName)
Calls when unbinds from queue.
|
public abstract String getName()
public abstract String getAppId()
public abstract void onBind(String queueName)
queueName
- the queue name.public abstract void onUnbind(String queueName)
queueName
- the queue name.public abstract void onReceive(String queueName, String contentType, Map<String,Object> headers, byte[] body)
queueName
- the queue name.contentType
- the type of content.headers
- the map of headers.body
- the content body.public static void fireOnReceive(String appId, String queueName, String contentType, Map<String,Object> headers, byte[] body)
appId
- the application id.queueName
- the queue name.contentType
- the type of content.headers
- the map of headers.body
- the message body.public static void fireOnBind(Collection<String> appIds, String queueName)
appIds
- the hashset of application ids.queueName
- the queue name.public static void fireOnUnbind(Collection<String> appIds, String queueName)
appIds
- the hashset of application ids.queueName
- the queue name.public static hudson.ExtensionList<MessageQueueListener> all()
Copyright © 2016–2018. All rights reserved.