|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface GatewayCommunicator
This interface is used by the ImportExportManager for communication with AALSpace Gateway Communicator via an OSGi service.
Field Summary | |
---|---|
static String |
ALIAS_PREFIX
Alias' prefix under which the HTTP servlet will be registered. |
static String |
EXPORT_SECURITY_CONSTRAINT_ALLOW
Property used for specifying bus members that are allowed to be exported to remote AAL Spaces. |
static String |
EXPORT_SECURITY_CONSTRAINT_DENY
Property used for specifying bus members that are denied to be exported to remote AAL Spaces. |
static String |
HASH_KEY
|
static String |
IMPORT_SECURITY_CONSTRAINT_ALLOW
Property used for specifying bus members that are allowed to be imported into this AAL Space. |
static String |
IMPORT_SECURITY_CONSTRAINT_DENY
Property used for specifying bus members that are denied to be imported into this AAL Space. |
static String |
LOCAL_SOCKET_PORT
|
static String |
REMOTE_GATEWAYS_PROP
System property used for specifying remote AAL Space Gateways addresses (host ip and port) in comma separated manner. |
Method Summary | |
---|---|
void |
handleMessage(InputStream in,
OutputStream out)
|
void |
sendContextEvent(Message message)
|
void |
sendContextEvent(Message message,
URL[] to)
Sends a context event to other AALSpace Gateway Communicators listening at given URL. |
void |
sendImportRefresh(Message message)
|
void |
sendImportRefresh(Message message,
URL[] to)
|
void |
sendImportRemoval(Message message)
|
void |
sendImportRemoval(Message message,
URL[] to)
|
Message |
sendImportRequest(Message message)
|
Message[] |
sendImportRequest(Message message,
URL[] to)
|
Message[] |
sendServiceRequest(Message message)
|
Message[] |
sendServiceRequest(Message message,
long timeout)
|
Message[] |
sendServiceRequest(Message message,
URL[] to)
Sends a service request to another AALSpace Gateway Communicator listening at given URL, waits for the response and returns it. |
Message[] |
sendServiceRequest(Message message,
URL[] to,
long timeout)
Sends a service request to another AALSpace Gateway Communicator listening at given URL, waits for the response and returns it if arrived before timing out. |
void |
sendServiceRequestAsync(Message message,
URL returnTo,
URL to,
ResponseCallback callback)
Sends a service request to another AALSpace Gateway Communicator listening at given URL, registers callback which will be notified once the response arrives. |
void |
sendUIRequest(Message message)
|
void |
sendUIRequest(Message message,
URL[] to)
Sends a ui request to other AALSpace Gateway Communicators listening at given URL. |
void |
sendUIResponse(Message message)
|
void |
sendUIResponse(Message message,
URL[] to)
Sends a ui response to other AALSpace Gateway Communicators listening at given URL. |
void |
start()
|
void |
stop()
|
Field Detail |
---|
static final String HASH_KEY
static final String REMOTE_GATEWAYS_PROP
static final String LOCAL_SOCKET_PORT
static final String IMPORT_SECURITY_CONSTRAINT_ALLOW
static final String EXPORT_SECURITY_CONSTRAINT_ALLOW
static final String IMPORT_SECURITY_CONSTRAINT_DENY
static final String EXPORT_SECURITY_CONSTRAINT_DENY
static final String ALIAS_PREFIX
Method Detail |
---|
Message[] sendServiceRequest(Message message, URL[] to)
message
- request massage to be sent to the remote communicatorto
- remote communicator's URL
Message[] sendServiceRequest(Message message)
Message[] sendServiceRequest(Message message, URL[] to, long timeout) throws TimeoutException
message
- request massage to be sent to the remote communicatorto
- remote communicator's URLtimeout
- time in milliseconds to wait for the response
TimeoutException
- when timed outMessage[] sendServiceRequest(Message message, long timeout) throws TimeoutException
TimeoutException
void sendServiceRequestAsync(Message message, URL returnTo, URL to, ResponseCallback callback)
message
- request massage to be sent to the remote communicatorreturnTo
- local communicator's URL to send back the response toto
- remote communicator's URLcallback
- callback which will be notified once the response arrivesvoid sendContextEvent(Message message, URL[] to)
message
- context event to be sentto
- a list of URLs of remote communicators to which the event
should be deliveredvoid sendContextEvent(Message message)
void sendUIResponse(Message message, URL[] to)
message
- ui responseto
- a list of URLs of remote communicators to which the event
should be deliveredvoid sendUIResponse(Message message)
void sendUIRequest(Message message, URL[] to)
message
- ui requestto
- a list of URLs of remote communicators to which the event
should be deliveredvoid sendUIRequest(Message message)
Message[] sendImportRequest(Message message, URL[] to)
Message sendImportRequest(Message message)
void sendImportRefresh(Message message, URL[] to)
void sendImportRefresh(Message message)
void sendImportRemoval(Message message, URL[] to)
void sendImportRemoval(Message message)
void handleMessage(InputStream in, OutputStream out) throws Exception
Exception
void stop()
void start() throws Exception
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |