public abstract class AbstractStompSessionManager extends ObjectSE implements StompSessionManager, ApplicationEventPublisherAware, SmartLifecycle, DisposableBean, BeanNameAware
ListenableFuture 上で単一の StompSession を管理するためのベース StompSessionManager 実装。StompSession への接続は、start() 中に行われます。
stop() ライフサイクルメソッドは StompSession.disconnect() を管理します。
connect(StompSessionHandler) および disconnect(StompSessionHandler) メソッドの実装は、提供された StompSessionHandler を内部 AbstractStompSessionManager.CompositeStompSessionHandler との間で入力 / 削除します。これにより、すべての操作が提供された StompSessionHandler に委譲されます。この AbstractStompSessionManager.CompositeStompSessionHandler は、StompSession 接続に使用されます。
| 修飾子と型 | フィールドと説明 |
|---|---|
protected Log | logger |
protected StompClientSupport | stompClient |
DEFAULT_PHASE| コンストラクターと説明 |
|---|
AbstractStompSessionManager(StompClientSupport stompClient) |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | connect(StompSessionHandler handler) |
void | destroy() |
void | disconnect(StompSessionHandler handler) |
protected abstract ListenableFuture<StompSession> | doConnect(StompSessionHandler handler) |
protected StompHeaders | getConnectHeaders() |
int | getPhase() |
long | getRecoveryInterval() |
boolean | isAutoReceiptEnabled() |
boolean | isAutoStartup() |
boolean | isConnected() |
boolean | isRunning() |
void | setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) |
void | setAutoReceipt(boolean autoReceipt) |
void | setAutoStartup(boolean autoStartup) |
void | setBeanName(StringSE name) |
void | setConnectHeaders(StompHeaders connectHeaders) |
void | setPhase(int phase) |
void | setRecoveryInterval(int recoveryInterval) 接続が失われた場合の再接続間隔をミリ秒単位で指定します。 |
void | start() |
void | stop() |
StringSE | toString() |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEstopprotected final Log logger
protected final StompClientSupport stompClient
public AbstractStompSessionManager(StompClientSupport stompClient)
public void setConnectHeaders(StompHeaders connectHeaders)
public void setAutoReceipt(boolean autoReceipt)
public boolean isAutoReceiptEnabled()
StompSessionManager の isAutoReceiptEnabled public boolean isConnected()
StompSessionManager の isConnected public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
ApplicationEventPublisherAware の setApplicationEventPublisher public void setBeanName(StringSE name)
BeanNameAware の setBeanName public void setRecoveryInterval(int recoveryInterval)
recoveryInterval - 接続が失われた場合のミリ秒単位の再接続間隔。public void setAutoStartup(boolean autoStartup)
public void setPhase(int phase)
public long getRecoveryInterval()
public boolean isAutoStartup()
SmartLifecycle の isAutoStartup public int getPhase()
Phased の getPhase SmartLifecycle の getPhase public void destroy()
DisposableBean の destroy public void connect(StompSessionHandler handler)
StompSessionManager の connect public void disconnect(StompSessionHandler handler)
StompSessionManager の disconnect protected StompHeaders getConnectHeaders()
public StringSE toString()
ObjectSE の toStringSE protected abstract ListenableFuture<StompSession> doConnect(StompSessionHandler handler)