Modifier and Type | Method and Description |
---|---|
protected void |
ConnectionImpl.handleBrowserUpdate(Message message) |
protected void |
ConnectionImpl.handleConditionData(Message message) |
protected void |
ConnectionImpl.handleConditionStatus(Message message) |
protected void |
ConnectionImpl.handleEventData(Message message) |
protected void |
ConnectionImpl.handleEventStatus(Message message) |
protected void |
ConnectionImpl.handleQueryData(Message message) |
protected void |
ConnectionImpl.handleQueryStateChange(Message message) |
Modifier and Type | Method and Description |
---|---|
protected void |
ServerConnectionHandler.acknowledge(Message message) |
protected void |
ServerConnectionHandler.handleCreateSessionComplete(Future<Session> future,
Message message,
Properties props) |
protected void |
ServerConnectionHandler.queryClose(Message message) |
protected void |
ServerConnectionHandler.queryCreate(Message message) |
protected void |
ServerConnectionHandler.queryLoadMore(Message message) |
protected void |
ServerConnectionHandler.subscribeEventPool(Message message) |
protected void |
ServerConnectionHandler.subscribeMonitors(Message message) |
protected void |
ServerConnectionHandler.unsubscribeEventPool(Message message) |
protected void |
ServerConnectionHandler.unsubscribeMonitors(Message message) |
Modifier and Type | Method and Description |
---|---|
void |
MessageFuture.messageReply(Message message) |
protected abstract T |
MessageFuture.process(Message message) |
protected void |
SessionConnectionBase.processSessionReply(Message message) |
Modifier and Type | Method and Description |
---|---|
static Message |
MessageHelper.closeSession() |
static Message |
MessageHelper.createPrivilegeChange(Set<String> privileges) |
static Message |
MessageHelper.createSession(Properties props)
Construct a CC_CREATE_SESSION message
|
static Message |
MessageHelper.createSessionACK(Message inputMessage,
Map<String,String> sessionProperties,
Map<String,String> transportProperties) |
Modifier and Type | Method and Description |
---|---|
static Message |
MessageHelper.createSessionACK(Message inputMessage,
Map<String,String> sessionProperties,
Map<String,String> transportProperties) |
static void |
MessageHelper.encodeOperationParameters(OperationParameters operationParameters,
Message message) |
static Set<String> |
MessageHelper.getPrivileges(Message message) |
protected void |
OperationController.sendACK(Message request,
long id) |
protected void |
OperationController.sendFailure(Message request,
Throwable e) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractServerConnectionHandler.replySessionCreated(Properties originalProperties,
Message originalMessage,
Map<String,String> sessionProperties) |
Modifier and Type | Method and Description |
---|---|
protected void |
Connection.performSubscriptionChange(Message message) |
Modifier and Type | Method and Description |
---|---|
static Message |
WriteOperation.create(String itemName,
Variant value,
OperationParameters operationParameters) |
static Message |
ListBrowser.createEvent(String[] path,
Collection<Entry> added,
Collection<String> removed,
boolean full) |
static Message |
ListBrowser.createRequest(String[] path) |
static Message |
WriteAttributesOperation.createRequest(String itemId,
Map<String,Variant> attributes,
OperationParameters operationParameters) |
static Message |
ListBrowser.createResponse(long id,
Entry[] entries) |
static Message |
ListBrowser.createResponse(long id,
String failure) |
static Message |
WriteAttributesOperation.createResponse(long id,
Throwable error) |
static Message |
WriteAttributesOperation.createResponse(long id,
WriteAttributeResults writeAttributeResults) |
static Message |
ListBrowser.createSubscribe(String[] path) |
static Message |
ListBrowser.createUnsubscribe(String[] path) |
static Message |
Messages.notifyData(String itemName,
Variant value,
Map<String,Variant> attributes,
boolean cache) |
static Message |
Messages.notifySubscriptionChange(String item,
SubscriptionState subscriptionState) |
static Message |
Messages.subscribeItem(String itemName) |
static Message |
Messages.unsubscribeItem(String itemName) |
Modifier and Type | Method and Description |
---|---|
static void |
WriteOperation.parse(Message message,
Holder<String> itemName,
Holder<Variant> value,
Holder<OperationParameters> operationParameters) |
static void |
ListBrowser.parseEvent(Message message,
List<String> path,
List<Entry> added,
List<String> removed,
Holder<Boolean> full) |
static String[] |
ListBrowser.parseRequest(Message message) |
static void |
WriteAttributesOperation.parseRequest(Message message,
Holder<String> itemId,
Holder<Map<String,Variant>> attributes,
Holder<OperationParameters> operationParameters) |
static WriteAttributeResults |
WriteAttributesOperation.parseResponse(Message message) |
static Entry[] |
ListBrowser.parseResponse(Message message) |
static String[] |
ListBrowser.parseSubscribeMessage(Message message) |
static void |
Messages.parseSubscriptionChange(Message msg,
Holder<String> item,
Holder<SubscriptionState> subscriptionState) |
static String[] |
ListBrowser.parseUnsubscribeMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
protected void |
ServerConnectionHandler.handleCreateSessionComplete(Future<Session> future,
Message message,
Properties props) |
Modifier and Type | Method and Description |
---|---|
protected void |
ConnectionImpl.handleListUpdate(Message message) |
protected void |
ConnectionImpl.handleQueryDataUpdate(Message message) |
protected void |
ConnectionImpl.handleQueryParameterUpdate(Message message) |
protected void |
ConnectionImpl.handleQueryStatusUpdate(Message message) |
Modifier and Type | Method and Description |
---|---|
static Message |
ItemListHelper.createRequestList(boolean flag) |
Modifier and Type | Method and Description |
---|---|
protected void |
ServerConnectionHandler.handleCloseQuery(Message message) |
protected void |
ServerConnectionHandler.handleCreateQuery(Message message) |
protected void |
ServerConnectionHandler.handleCreateSessionComplete(Future<Session> future,
Message message,
Properties props) |
protected void |
ServerConnectionHandler.handleUpdateQueryParameters(Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
LongRunningOperation.getReply() |
Modifier and Type | Method and Description |
---|---|
void |
LongRunningController.messageReceived(Message message) |
void |
MessageListener.messageReceived(Message message) |
void |
MessageStateListener.messageReply(Message message) |
protected void |
LongRunningOperation.result(Message message) |
LongRunningOperation |
LongRunningController.start(Message message,
LongRunningListener listener) |
Modifier and Type | Method and Description |
---|---|
void |
PingHandler.messageReceived(Message message) |
void |
PongHandler.messageReceived(Message message) |
Modifier and Type | Method and Description |
---|---|
org.apache.mina.core.buffer.IoBuffer |
GMPPProtocolEncoder.code(Message message) |
protected boolean |
Messenger.handleDefaultMessage(Message message) |
protected boolean |
Messenger.handleHandlerMessage(Message message) |
protected void |
Messenger.handleUnknownMessage(Message message) |
void |
Messenger.messageReceived(Message message) |
void |
PrepareSendHandler.prepareSend(Message message) |
org.apache.mina.core.future.WriteFuture |
Messenger.sendMessage(Message message) |
org.apache.mina.core.future.WriteFuture |
Messenger.sendMessage(Message message,
MessageStateListener messageListener) |
org.apache.mina.core.future.WriteFuture |
Messenger.sendMessage(Message message,
MessageStateListener listener,
long timeout)
Send out a message including optional message tracking
|
org.apache.mina.core.future.WriteFuture |
IoSessionSender.sendMessage(Message message,
PrepareSendHandler handler) |
org.apache.mina.core.future.WriteFuture |
MessageSender.sendMessage(Message message,
PrepareSendHandler prepareSendHandler)
Send a message out to somewhere
|
Modifier and Type | Method and Description |
---|---|
static Message |
MessageCreator.createACK(Message inputMessage) |
static Message |
MessageCreator.createFailedMessage(Message inputMessage,
int commandCode,
String failMessage) |
static Message |
MessageCreator.createFailedMessage(Message inputMessage,
String failMessage) |
static Message |
MessageCreator.createFailedMessage(Message inputMessage,
Throwable error) |
static Message |
MessageCreator.createPing() |
static Message |
MessageCreator.createPong(Message inputMessage) |
static Message |
MessageCreator.createUnknownMessage(Message inputMessage) |
Modifier and Type | Method and Description |
---|---|
static Message |
MessageCreator.createACK(Message inputMessage) |
static Message |
MessageCreator.createFailedMessage(Message inputMessage,
int commandCode,
String failMessage) |
static Message |
MessageCreator.createFailedMessage(Message inputMessage,
String failMessage) |
static Message |
MessageCreator.createFailedMessage(Message inputMessage,
Throwable error) |
static Message |
MessageCreator.createPong(Message inputMessage) |
static Message |
MessageCreator.createUnknownMessage(Message inputMessage) |
Copyright © 2016 Eclipse SCADA Project. All rights reserved.