Package | Description |
---|---|
com.streamscape.cli.http | |
com.streamscape.cli.tlp | |
com.streamscape.omf.mapper.parser | |
com.streamscape.sef.dispatcher | |
com.streamscape.sef.group |
Modifier and Type | Method and Description |
---|---|
java.nio.charset.Charset |
HTTPFabricConnection.getCCSID() |
DomainConstraint |
HTTPSemanticMapperContext.getDomainConstraint(java.lang.String domainName) |
EventCache |
HTTPFabricConnection.getEventCache(java.lang.String eventFilter) |
ExceptionStrategy |
HTTPFabricConnection.getExceptionStrategy() |
FabricGroupManager |
HTTPFabricConnection.getGroupManager() |
java.util.TimeZone |
HTTPFabricConnection.getHostTimezone() |
java.util.TimeZone |
HTTPFabricConnection.getNodeTimezone() |
RangeConstraint |
HTTPSemanticMapperContext.getRangeConstraint(java.lang.String rangeName) |
void |
HTTPFabricConnection.importEventPrototype(java.lang.String eventId) |
java.util.List |
HTTPFabricConnection.listGroups() |
long |
HTTPFabricConnection.nextGlobalCount() |
void |
HTTPFabricConnection.open(long timeout) |
long |
HTTPFabricConnection.resetGlobalCounter() |
void |
HTTPFabricConnection.setExceptionListener(FabricEventListener listener) |
void |
HTTPFabricConnection.setExceptionStrategy(ExceptionStrategy exceptionStrategy) |
void |
HTTPFabricConnection.setSecurityToken(java.lang.String token) |
long |
HTTPFabricConnection.showGlobalCounter() |
Modifier and Type | Method and Description |
---|---|
void |
FabricConnection.acknowledgeEvent(EventDatagram event,
boolean withSourceData,
AcknowledgeAction action,
java.lang.String recipientId,
EventScope eventScope,
long timeToLive)
Raises an acknowledgement on the specified event.
|
void |
FabricConnection.acknowledgeException(ExceptionEventDatagram ex,
AcknowledgeAction action,
java.lang.String recipientId,
EventScope eventScope,
long timeToLive)
Raises an acknowledgement on the specified exception event.
|
void |
FabricConnection.addEventCache(java.lang.String eventFilter,
int maxSize,
CacheThresholdAction thresholdAction)
Adds a new event cache.
|
void |
FabricConnection.addURL(java.lang.String url)
Adds the specified URL to the list of URLs.
|
void |
FabricConnection.bindProducerFor(java.lang.String eventId)
Binds the specified event identifier to the connection.
|
void |
FabricConnection.close()
Closes the connection.
|
void |
FabricConnection.close(long timeout)
Closes the connection.
|
DataspaceAccessor |
FabricConnection.createDataspaceAccessor(DataspaceType dataspaceType,
java.lang.String dataspaceName)
Creates an accessor to the dataspace with the specified type and name.
|
DataspaceAccessor |
FabricConnection.createDataspaceAccessor(java.lang.String nodeName,
DataspaceType dataspaceType,
java.lang.String dataspaceName)
Creates an accessor to the dataspace with the specified type and name.
|
DomainConstraint |
FabricConnection.createDomainConstraint(java.lang.String domainName,
java.lang.String description,
java.util.Set values)
Creates a new Domain Constraint with the specified parameters.
|
EventAsyncConsumer |
FabricConnection.createEventAsyncConsumer(java.lang.String consumerName,
FabricEventListener listener,
java.lang.String eventFilter,
java.lang.String eventSelector,
EventScope eventScope,
boolean noLocal)
Creates a new event asynchronous consumer and adds this consumer the dispatcher.
|
EventConsumer |
FabricConnection.createEventConsumer(java.lang.String consumerName,
FabricEventListener listener,
java.lang.String eventFilter,
java.lang.String eventSelector,
EventScope eventScope,
boolean noLocal)
Creates a new event consumer and adds this consumer to the dispatcher.
|
EventReceiver |
FabricConnection.createEventReceiver(java.lang.String receiverName,
java.lang.String eventFilter,
java.lang.String eventSelector,
EventScope eventScope,
boolean noLocal)
Creates a new event receiver and adds this receiver to the the dispatcher.
|
RangeConstraint |
FabricConnection.createRangeConstraint(java.lang.String rangeName,
java.lang.String description,
java.lang.Object minValue,
java.lang.Object maxValue)
Creates a new Range Constraint with the specified parameters.
|
EventRequestConsumer |
FabricConnection.createRequestConsumer(java.lang.String consumerName,
FabricRequestListener listener,
EventScope eventScope)
Creates a new event request consumer and adds this consumer the dispatcher.
|
ServiceAccessor |
FabricConnection.createServiceAccessor(java.lang.String serviceType,
java.lang.String serviceName)
Creates an accessor to a service with the specified type and name.
|
ServiceAccessor |
FabricConnection.createServiceAccessor(java.lang.String nodeName,
java.lang.String serviceType,
java.lang.String serviceName)
Creates an accessor to a service with the specified type and name.
|
SLSession |
FabricConnection.createSLSession()
Creates a
Semantic Language session to the current node. |
SLSession |
FabricConnection.createSLSession(java.lang.String nodeName)
Creates a
Semantic Language session to the Fabric node with the specified name. |
void |
FabricConnection.dropConsumer(java.lang.String consumerName)
Drops a consumer with the specified name.
|
void |
FabricConnection.dropDomainConstraint(java.lang.String domainName)
Drops a Domain Constraint with the specified name.
|
void |
FabricConnection.dropEventAsyncConsumer(java.lang.String consumerName)
Drops an event asynchronous with the specified name.
|
void |
FabricConnection.dropEventConsumer(java.lang.String consumerName)
Drops an event consumer with the specified name from the dispatcher.
|
void |
FabricConnection.dropEventReceiver(java.lang.String receiverName)
Drops a receiver with the specified name.
|
void |
FabricConnection.dropRangeConstraint(java.lang.String rangeName)
Drops a Range Constraint with the specified name.
|
void |
FabricConnection.dropRequestConsumer(java.lang.String consumerName)
Drops an event request with the specified name.
|
void |
FabricConnection.exportEventPrototype(java.lang.String eventId)
Exports an Event Prototype with the specified event id to the Fabric node with which the connection established.
|
void |
FabricConnection.exportExtensionArchive(java.io.File jarFile)
Exports the specified JAR file to the Fabric node with which the connection established.
|
void |
FabricConnection.exportSemanticType(java.lang.String typeName)
Exports the specified Semantic Type to the Fabric node with which the connection established.
|
void |
FabricConnection.forceClose()
Forcibly closes the connection.
|
AuthenticationType |
FabricConnection.getAuthenticationType()
Returns an authentication type of the connection.
|
java.nio.charset.Charset |
FabricConnection.getCCSID()
Returns a
CCSID configured in the current Fabric node. |
ComponentReference |
FabricConnection.getComponentReference()
Returns a
ComponentReference associated with the connection. |
DomainConstraint |
FabricConnection.getDomainConstraint(java.lang.String domainName)
Finds and returns a copy of Domain Constraint with the specified name.
|
EventAsyncConsumer |
FabricConnection.getEventAsyncConsumer(java.lang.String consumerName)
Finds and returns an event asynchronous consumer with the specified name.
|
EventCache |
FabricConnection.getEventCache(java.lang.String eventFilter)
Returns an event cache associated with the specified simple event filter.
|
EventConsumer |
FabricConnection.getEventConsumer(java.lang.String consumerName)
Finds and returns an event consumer with the specified name.
|
EventReceiver |
FabricConnection.getEventReceiver(java.lang.String receiverName)
Finds and returns an event receiver with the specified name.
|
ExceptionStrategy |
FabricConnection.getExceptionStrategy()
Returns an exception strategy of the connection.
|
FabricAddress |
FabricConnection.getFabricAddress()
Returns a Fabric address of the connection.
|
FabricGroupLink |
FabricConnection.getGroupLink(java.lang.String groupName)
Returns a link to the specified group if the connection is a member of this group.
|
FabricGroupManager |
FabricConnection.getGroupManager()
Returns a Fabric Group Manager associated with the connection.
|
java.util.TimeZone |
FabricConnection.getHostTimezone()
Returns a timezone of the host where the current Fabric node is running.
|
Moderator |
FabricConnection.getModerator()
Returns a moderator associated with the connection.
|
java.util.TimeZone |
FabricConnection.getNodeTimezone()
Returns a timezone configured in the current Fabric node.
|
RangeConstraint |
FabricConnection.getRangeConstraint(java.lang.String rangeName)
Finds and returns a copy of Range Constraint with the specified name.
|
int |
FabricConnection.getReconnectAttempts()
Returns a number of reconnect attempts that will be made by the connection in a case of the remote node disconnection.
|
long |
FabricConnection.getReconnectInterval()
Returns a time (in seconds) between successive reconnect attempts that will be made by the connection
in a case of the remote node disconnection.
|
RepositoryAccessor |
FabricConnection.getRepositoryAccessor()
Returns an accessor to the Repository located in the current node.
|
RepositoryAccessor |
FabricConnection.getRepositoryAccessor(java.lang.String nodeName)
Returns an accessor to the Repository located in the node with the specified name.
|
EventRequestConsumer |
FabricConnection.getRequestConsumer(java.lang.String consumerName)
Finds and returns an event request consumer with the specified name.
|
SecurityManager |
FabricConnection.getSecurityManager()
Returns a Security Manager associated with the connection.
|
boolean |
FabricConnection.hasBoundEventIds()
Checks if the connection has bound event identifiers.
|
void |
FabricConnection.importEventPrototype(java.lang.String eventId)
Imports an Event Prototype with the specified event id from the Fabric node with which the connection established.
|
void |
FabricConnection.importExtensionArchive(java.lang.String archiveName)
Imports the specified extension archive from the Fabric node with which the connection established.
|
void |
FabricConnection.importPackage(java.lang.String packageName)
Imports all archives of the specified Package from the Fabric node with which the connection established.
|
void |
FabricConnection.importSemanticType(java.lang.String typeName)
Imports the specified Semantic Type from the Fabric node with which the connection established.
|
boolean |
FabricConnection.isBoundEventId(java.lang.String eventId)
Checks if the specified event identifier is bound to the connection.
|
boolean |
FabricConnection.isReconnecting()
Checks if the remote node has disconnected and the connection is ready for reconnecting (or reconnecting is in progress).
|
boolean |
FabricConnection.isSecurityEnabled()
Checks if the security is enabled in the Fabric.
|
FabricGroupLink |
FabricConnection.joinGroup(java.lang.String groupName)
Joins the specified group.
|
void |
FabricConnection.leaveGroup(java.lang.String groupName)
Leaves the specified group.
|
java.util.List |
FabricConnection.listBoundEventIds()
Returns a list of event identifiers bound to the connection.
|
java.util.List |
FabricConnection.listEventAsyncConsumers()
Returns a list of names of all event asynchronous consumers of this connection.
|
java.util.List |
FabricConnection.listEventConsumers()
Returns a list of names of all event consumers of this connection.
|
java.util.List |
FabricConnection.listEventReceivers()
Returns a list of names of all event receivers of this connection.
|
java.util.List |
FabricConnection.listGroups()
Returns a list of the names of all groups to which the connection has joined.
|
java.util.List |
FabricConnection.listRequestConsumers()
Returns a list of names of all event request consumers of this connection.
|
long |
FabricConnection.nextGlobalCount()
Increments the
Global Counter and returns its new value. |
void |
FabricConnection.open()
Opens the connection.
|
void |
FabricConnection.open(long timeout)
Opens the remote connection with the specified timeout (in seconds) using the list of URls (@see
FabricConnection.addURL(String) . |
void |
FabricConnection.raiseAcknowledgement(AcknowledgementEvent event,
EventScope eventScope,
long timeToLive)
Raises the specified acknowledgment event.
|
void |
FabricConnection.raiseAdvisory(AdvisoryEventDatagram event,
EventScope eventScope)
Raises the specified advisory event.
|
void |
FabricConnection.raiseEvent(ImmutableEventDatagram event,
EventScope eventScope,
long timeToLive)
Raises the specified event.
|
void |
FabricConnection.raiseException(ExceptionEventDatagram event,
EventScope eventScope)
Raises the specified exception event.
|
AcknowledgementEvent |
FabricConnection.raiseRequest(EventDatagram request,
EventScope eventScope,
RequestDistributionStrategy distributionStrategy,
ReplyMatchStrategy matchStrategy,
long timeout)
Raises the specified request and waits until a reply will be received or timeout period will expire.
|
ImmutableEventDatagram |
FabricConnection.raiseRequest(RequestConsumerReference consumer,
ImmutableEventDatagram request,
long timeout)
Raises the specified request and waits until a reply will be received or waiting period expires.
|
void |
FabricConnection.removeEventCache(java.lang.String eventFilter)
Removes an event cache associated with the specified simple event filter.
|
long |
FabricConnection.resetGlobalCounter()
Resets the
Global Counter , setting its value to 1 . |
void |
FabricConnection.setClientId(ClientId clientId)
Sets the specified connection Client ID.
|
void |
FabricConnection.setDescription(java.lang.String description)
Sets the specified connection description.
|
void |
FabricConnection.setDomainConstraint(DomainConstraint domain)
Updates the existing domain obtained by the method
#createDomainConstraint(String)
or FabricConnection.getDomainConstraint(String) . |
void |
FabricConnection.setEventScope(EventScope eventScope)
Sets the specified event scope.
|
void |
FabricConnection.setExceptionListener(FabricEventListener listener)
Sets the listener that will process all exception events raised in the node or sysplex.
|
void |
FabricConnection.setExceptionStrategy(ExceptionStrategy exceptionStrategy)
Sets the specified exception strategy of the connection.
|
void |
FabricConnection.setName(java.lang.String name)
Sets the specified connection name.
|
void |
FabricConnection.setPassword(java.lang.String password)
Sets the specified user password of the connection.
|
void |
FabricConnection.setRangeConstraint(RangeConstraint range)
Updates the existing range obtained by the method
FabricConnection.createRangeConstraint(String, String, Object, Object)
or FabricConnection.getRangeConstraint(String) . |
void |
FabricConnection.setReconnectAttempts(int reconnectAttempts)
Sets a number of reconnect attempts that will be made by the connection in a case of the remote node disconnection.
|
void |
FabricConnection.setReconnectInterval(long reconnectInterval)
Sets a time (in seconds) between successive reconnect attempts that will be made by the connection
in a case of the remote node disconnection.
|
void |
FabricConnection.setSecurityToken(java.lang.String token)
Sets the specified
Web Application Token for the connection. |
void |
FabricConnection.setUserName(java.lang.String userName)
Sets the specified user name of the connection.
|
long |
FabricConnection.showGlobalCounter()
Returns the current value of the
Global Counter . |
void |
FabricConnection.unbindProducerFor(java.lang.String eventId)
Unbinds the specified event identifier from the connection.
|
Constructor and Description |
---|
ClientId(java.lang.String stringForm)
Creates a new id using the specified string form (
name1=value1,...,nameN=valueN ). |
Modifier and Type | Method and Description |
---|---|
DomainConstraint |
SemanticMapperContext.getDomainConstraint(java.lang.String domainName) |
DomainConstraint |
LocalSemanticMapperContext.getDomainConstraint(java.lang.String domainName) |
RangeConstraint |
SemanticMapperContext.getRangeConstraint(java.lang.String rangeName) |
RangeConstraint |
LocalSemanticMapperContext.getRangeConstraint(java.lang.String rangeName) |
Modifier and Type | Method and Description |
---|---|
DataspaceAccessor |
TriggerFunctionContextImpl.DataspaceAccessorProvider.getDataspaceAccessor() |
DataspaceAccessor |
DataspaceAccessorProviderForTaskList.getDataspaceAccessor() |
Modifier and Type | Method and Description |
---|---|
EventAsyncConsumer |
FabricGroupLink.createEventAsyncConsumer(java.lang.String consumerName,
FabricEventListener listener,
java.lang.String eventFilter,
java.lang.String eventSelector,
EventScope eventScope,
boolean noLocal)
Creates a new event asynchronous consumer and adds this consumer the link's dispatcher.
|
EventReceiver |
FabricGroupLink.createEventReceiver(java.lang.String receiverName,
java.lang.String eventFilter,
java.lang.String eventSelector,
EventScope eventScope,
boolean noLocal)
Creates a new event receiver and adds this receiver to the the link's dispatcher.
|
void |
FabricGroupLink.dropEventAsyncConsumer(java.lang.String consumerName)
Drops an event asynchronous with the specified name from the link's dispatcher.
|
void |
FabricGroupLink.dropEventReceiver(java.lang.String receiverName)
Drops a receiver with the specified name.
|
EventAsyncConsumer |
FabricGroupLink.getEventAsyncConsumer(java.lang.String consumerName)
Finds and returns an event asynchronous consumer with the specified name.
|
EventReceiver |
FabricGroupLink.getEventReceiver(java.lang.String receiverName)
Finds and returns an event receiver with the specified name.
|
void |
FabricGroupLink.leaveGroup()
Leaves the group.
|
java.util.List |
FabricGroupLink.listEventAsyncConsumers()
Returns a list of names of all event asynchronous consumers of the connection.
|
java.util.List |
FabricGroupLink.listEventReceivers()
Returns a list of names of all event receivers.
|
void |
FabricGroupLink.raiseEvent(ImmutableEventDatagram event,
EventScope eventScope,
long timeToLive)
Raises the specified event.
|
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.