|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
identity
within a Map.IConnectionDiscoverer instances.FieldReader when reading messagesIField instances being added or
removed from an IContainer.FieldReader when reading messagesIEvent instances that are marker events.IEvent.AbstractContainer that includes logic to handle event
processing.IField implementations.IField.ILifeCycle instances.SelectionKey that is set by the
SelectorTasks.SocketChannel connection to a remote IFrameworkContext
instance.ISystemEvent instances.Confirmed state and encapsulates the logic the
FTContext needs to perform to go into the active state.
AsymmetricEventProcessor.EventProcessor to execute the update logic.IEventListener and pushes all events into the
delegate using an internal EventProcessor.
IEventListener and pushes all events into the
delegate using an internal EventProcessor.
IEventSource.addListener(IEventListener).
IEventListener instances with the event.
IEventListener instances associated with
this ISubscription.
IEventListener instances associated with
the ISubscription represented by the parameters.
ContainerStateChangeEvent events
generated by the container.
IAddressable objectAbstractLifeCycle.start().AsymmetricEventProcessor.Log and executes the logging operations using an
ITaskExecutor.Log identified by the name
Log identified by the class
Map of objects against their key.BooleanFieldChannel has completed its destroy sequence.Channel.IChannel is ready - this means the channel can now be
used.IEventListener that a Channel uses to
receive IEvents in the local context and forward them on to the
remotely connected context connected to the channel.Collection implementation that is backed by an internal map.Collection instances.Collection instances.Collection instances.IConnectionBroker.
IConnectionBroker.
IConnection implementation and includes
the connection to the remote IFrameworkContext that is available for
use.IFrameworkContext
ConnectionDestroyedEvent from the
AbstractConnectionDiscoverer.current map of known connections.
IConnection implementation and represents
that the connection has been destroyed.IFrameworkContext that the destroyed connection was for
IContainer has been created.IContainerDefinitionField.IContainer has been destroyed.IContainer implementations.IField is added to an IContainer instance.IField is removed from an IContainer instance.IContainer has a change in its state.IContainer
instances.ContainerSubscription instances.ISubscriptionManager for
IContainer subscriptions.IField instance with an identity equal
to the key argument.
DescriptorField
for a field identified by its integer wire identity.
IContainerFactory.IContainerBuilder
(and by association, an IContainerDefinitionField) registered
against the IContainer type argument.
IContainerFactory.IContainerBuilder
(and by association, an IContainerDefinitionField) registered
against the IContainer type argument.
IConnectionDiscoverer implementation and encapsulates
the connection details to a remote IFrameworkContext.IFrameworkContext
IConnectionDiscoverer when a remote context is no longer
available.IFrameworkContext that is no longer available.
Class objects passed in.
IContainer implementation from the type argument.
IContainer implementation from the type argument.
IContainer
IContainerDefinitionField to use for instances of the
container this builder creates.
Class objects passed in.
IField using the parameters passed in.
IField using the simple class name and
the name for the field
IField using the simple class name and
the name for the field
ISubscription instance.
byte[] into the RPC marker, key, identity of the
remote context invoking this RPC and arguments.
Object[] arguments
RPC_TIMEOUT
default application and
default permission code.ISelectionKeyTask.run() method to a
ISelectionKeyTask.IField in a container.MessageConsumedEventHandler that the
connection should be destroyed when all messages have been consumed.
Class.
SubscriptionManager.addListener(ISubscriptionParameters, IEventListener).
IEventSource that
originated from the remote context this channel connects to, when the
channel is destroyed.
EventProcessor
SubscriptionManager.eventSourceCreated(IAddressable)
method.
IEventSource identified by the
IAddressable argument exists.
IEventSource identified by the
IAddressable argument exists.
IEventSource identified by the
IAddressable argument.
IEventSource identified by the
IAddressable argument.
IEventSource instances
the manager will operate over.
IDomain implementation backed by an
IAutoCreatingStore that returns canonical IDomain instances.IEventListener has been added via
AbstractComponent.addListener(IEventListener)
IEventListener has been removed via
AbstractComponent.removeListener(IEventListener)
IConnectionBroker
AbstractContainer.dataState changes.
DoubleFieldIEvent.getFrame()
in preparation for a matching driven events (matched using the driven
event's IEvent.getDrivingFrame()).
System.out.
byte[]
boolean arguments
byte arguments
char arguments
short arguments
integer arguments
long arguments
float arguments
double arguments.
boolean[] arguments
byte[] arguments
char[] arguments
short[] arguments
int[] arguments
long[] arguments
float[] arguments
double[] arguments
Object[] arguments
IEventFrameExecution.IEvent objects off a task
queue, finds the IEventListener instances registered against the
IEventSource that generated the event, determines if the event is
compatible with the events the listener can accept (see
IEventListener.getEventTypeFilter()) and calls
IEventListener.update(IEvent) if the event is compatible.IEventSource is created.
IEventSource operations of this
IEventSource is destroyed.
IEventSource has no more
IEventListener instances observing it.IEventListener instance has been
added as an observer to an IEventSource.IRpcResult.getExceptionMessage() attribute
IOperationScope.include(Object).
FieldReader#readIWFFieldSpecs(byte[], int, int, int, int, IFieldReaderTask)
and
FieldReader#readSWFFieldSpecs(byte[], int, int, int, int, IFieldReaderTask)
methods.IField instancesFloatFieldByteConstants.ENCODING.
DistributionManager for an FTContext.TcpNetwork subclass that configures the discoverer to use default
UDP parameters for an FT cluster.IFrameworkContext implementation composed of
collaborating implementations:
IModelManager
IEventManager
IDistributionManager
IRpcManager
Domain instance.
Type instance.
getArgString
BooleanField identified by the identity
BooleanField identified by the identity
ByteConstants.ENCODING.
IConnectionParameters.getRemoteContextIdentity()).
IFrameworkContext
IConnectionDiscoverer.
IFrameworkContext
byte[] message from the remote context
IContainerDefinitionField registered against the
IContainer type argument.
IContainerDefinitionField registered against the
IContainer type argument.
IRpcDefinition registered against the RPC registry key.
DoubleField identified by the identity
DoubleField identified by the identity
AsymmetricEventProcessor.
AbstractEventHandler instances, this method
returns a map of the handlers indexed by the IEvent class each
one handles.
EventProcessor instances in this context
ThreadGroup for the event processors.
IEvent instances this listener can process.
FloatField identified by the identity
FloatField identified by the identity
IntegerField identified by the identity
IntegerField identified by the identity
IEventListener instances observing this.
List of all the
IEventListener instances used by the subscription to register
against the subscribed IEventSource instances.
IEventListener instances that have been
added to the subscription identified by the parameters.
LongField identified by the identity
LongField identified by the identity
Collection of all the
IEventSource instances referenced by this subscription.
IEventSource is native to;
its local context
IConnectionDiscoverer
instances over the discovery network
IRpcDefinition for the procedure.
IRpcDefinition for the procedure.
IFrameworkContext at the remote end of
the connection
IFrameworkContext that the
destroyed connection was for
IRemoteUpdateInvoker to use for updating remote
containers
RpcDefinition this invocation is
for
Runnable to continually execute the SelectorTasks.process()
method.
RxSubscription instances.
EventProcessor
StringField identified by the identity
StringField identified by the identity
Collection of all the event sources that
are currently subscribed for.
Collection of the currently subscribed
event sources that are matched by the subscription parameters.
ISystemEventSource that is used to propagate a single
specific type of ISystemEvent.
TxSubscription instances.
IField identified by the
string
AbstractConnectionDiscoverer.heartbeatGenerator
AbstractConnectionDiscoverer.heartbeatListener
AbstractConnectionDiscoverer.heartbeatProcessor
AbstractEvent.toString() calls.
IFrameworkContext instances.IChannel implementationChannel to interact with it.ChannelCollection instances.IFrameworkContext and
a remote context.IFrameworkContext instances that have
connected to the communication network.IConnection.IContainer.IField objects in an IContainer object.IFrameworkContext to create IContainer
instancesIContainer.IEventListener instances when specific IContainer
instances generate a ContainerStateChangeEvent.IFrameworkContext.Object.toString() method.DistributionManager.IAddressable entity.IEventSource object into a unit
of work.IEventFrame.IEventSource instances.IEvent objects.IField.ISubscription instance whose
subscription parameters include the parameters passed in.
IAddressable attributes of this parameters
instance would include those of another.
IFulmineContext to a specific network transport.IntegerFieldIFulmineContext.IEventListener.List that only allows unique elements and keeps a count of the
number of attempts to add the element.IRemoteUpdateHandler.handle(String, int, int, String, String, int, int, String)
method.RpcManager can
use.IRpcManager.invoke(IRpcResultHandler, String, String, IField...) .Object.equals(Object) method.IRpcResult.isSuccessful() attribute
IChannel has been
synchronised.
IFrameworkContext is healthy or not.
SelectionKey.SelectorTasks object.IContainer.getContext()
IEventManager.queueEvent(fulmine.event.IEvent) as being a
statistics event and should thus not log statistics about the event.
ISubscription that has a match
reference for the event source.
IEventSource instances.ISubscription instances.IContainer is subscribed or
unsubscribed for, when the first IEventListener is added and when
there are no more listeners.IEvent events generated by
IEventSource instances.IEventSource.ISystemEvent instances.ISystemEvent events.IAddressable entity.IWireIdentity assigned to a
String identity.JCheckBox as the UI.JTextField as the UI.System.err if the log level is
not enabled.
LongFieldMap that has List values.Map that has Set values.MessageEvent has been consumed by all
IEventListener instances.IConnection and encapsulates a byte[]
message received from a remote IFrameworkContext.byte[] message from a
remote IFrameworkContext
IEventListener objects that each handle a specific type of
IEvent.MultiEventListener that handles system events.List implementation with its implementation default
size.
List implementation from another Collection
instance size.
List implementation with the given size.
List implementation with its implementation default
size.
List implementation from another Collection
instance size.
List implementation with the given size.
Map implementation with the implementation default
size.
Map implementation with the given size.
Map implementation with the given size and
loadFactor.
Map implementation from another instance.
Map implementation with the implementation default
size.
Map implementation with the given size.
Map implementation with the given size and
loadFactor.
Map implementation from another instance.
Map implementation with the implementation default
size.
Queue implementation with the implementation default
size.
Queue implementation with the given size.
Queue implementation with the implementation default
size.
Queue implementation with the given size.
AbstractContainer.doReadState(IOperationScope, byte[], int, int) method.
Set implementation with the given size.
Set implementation from another Collection
instance.
Set implementation with the implementation default
size.
Set implementation with the given size.
Set implementation from another Collection
instance.
Set implementation with the implementation default
size.
Map implementation with the given size.
Map implementation with the given size.
Map implementation with the given size.
Map implementation with the given size.
null
Selector
Collection implementation that is backed by a map implementation
that maintains insertion order of items.start.
MultiEventListener refinement that is marked as a priority
listener.Selector.select() and wait for a one of the operations in
any of the registered channels to occur.
Record called "time" that has a
single component "date".IConnectionBroker connections.
IEventListener instances for the event's IEventSource.
Record instances as rows.List implementation backed by an internal list.Selector with the channel and map the
supplied task to the SelectionKey that is returned from the
SelectableChannel.register(Selector, int) method.
IContainerFactory.IContainerBuilder against the
IContainer type.
IContainerFactory.IContainerBuilder against the
IContainer type.
IContainer has been created.IContainer has been destroyed.DescriptorField with the same identity as the field
argument from this definition.
TtlSet.remove(Object).
IEventSource.removeListener(IEventListener).
IEventListener instances associated
with this ISubscription.
IEventListener instances associated
with the ISubscription represented by the parameters.
ContainerStateChangeEvent
events generated by the container.
IEvent events
originating from this.
IContainer instances with matching type and identity
subscribe for by the local context.
IContainer instances with matching type
and identity.
IContainer instances subscribed for by the local
context.
IContainer instances subscribed for by the local
context.
IRpcResult.getResult()
attribute
IContainer instances with
matching type and identity to the (connected) remote context.
IContainer instances with
matching type and identity to the connected remote context.
IContainer instances
that the (connected) remote context has subscribed for.
IContainer instances
that the connected remote context has subscribed for.
IContainer instances to
all (connected) remote contexts that have a subscription for the
container instances.
IContainer instances with
matching type and identity to all (connected) remote contexts that have a
subscription for the matching container.
IRpcCodec.IRpcDefinition.IRpcManager.IRpcRegistry implementation.byte[] that holds the state
change in wire form of an IContainer received from a remote context.IFrameworkContext.RxSubscription instancestoString() method on the target.
Selector of the SelectorTasks has been opened.
ISelectionKeyTask objects that handle the logic for
the ready operations raised from registered NIO Channel objects.IFrameworkContext.
RpcCodec.getRpcKey() and
RpcCodec.getArgs()
IConnectionDiscoverer returned from
INetwork.createDiscoverer() into listening-only mode.
INetwork for the context.
SelectableChannel.register(java.nio.channels.Selector, int)
method called during the
SelectorTasks.register(int, SelectableChannel, ISelectionKeyTask)
method.
IField instances held in this container
Standby state and encapsulates the logic the
FTContext needs to perform to go into standby state.
IFrameworkContext instances
ThreadUtils.LOG at the Log.info(Object) level.
StringFieldIContainer
instance(s) in the identified context that match the type, domain and
identity regular expression.
ISubscription for the event source(s) represented in
the subscription parameters.
ISubscriptionManager receives a new
subscription.TcpConnectionBroker port and
subscribes to a IConnectionBroker identity "Publisher" for an
IContainer called "time" and prints each event to the console.Subscription instancesISubscriptionParametersIWireIdentity for DescriptorField objects.ITaskHandler.Executor for tasks.IFrameworkContext.TcpConnectionBroker using parameters for the
identity, IP address and TCP port.
IFrameworkContext to connect to.IConnectionBroker.
Set implementation backed by an internal set.TtlSet.
TtlSet with the specified TTL for any new entry
added.
byte[] that holds the
state change in wire form of an IContainer to transmit.IContainer to a remote
IFrameworkContext.TxSubscription instances.IType implementation backed by an
IAutoCreatingStore that returns canonical IType instances.IRpcPublishOperations.publishRpcs(Class, Object)
ISelectionKeyTask.
IContainer instance(s)
identified by the type, domain and identity regular expression in the
specified context.
ISubscriptionManager removes a
subscription.IEvent objects generated by the
driver and driven IEventSource objects.
IWireIdentity interface.
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||