- raise(Object, T) - Method in class eneter.net.system.EventImpl
-
Raises the event to all subscribers.
- read() - Method in class eneter.messaging.dataprocessing.streaming.DynamicInputStream
-
Reads one byte from the stream.
- read(byte[], int, int) - Method in class eneter.messaging.dataprocessing.streaming.DynamicInputStream
-
Reads data from the stream to the specified buffer.
- receiveMessage() - Method in interface eneter.messaging.messagingsystems.websocketmessagingsystem.IWebSocketClientContext
-
Waits until a message is received from the client.
- registerMessageHandler(IMethod1<TMessage>) - Method in class eneter.messaging.dataprocessing.messagequeueing.WorkingThread
-
Registers the method handling messages from the queue and starts the thread reading messages from the queue.
- registerRequestMessageReceiver(EventHandler<TypedRequestReceivedEventArgs<T>>, Class<T>) - Method in interface eneter.messaging.endpoints.typedmessages.IMultiTypedMessageReceiver
-
Registers message handler for specified message type.
- registerResponseMessageReceiver(EventHandler<TypedResponseReceivedEventArgs<T>>, Class<T>) - Method in interface eneter.messaging.endpoints.typedmessages.IMultiTypedMessageSender
-
Registers response message handler for specified message type.
- removeAllDuplexOutputChannels() - Method in interface eneter.messaging.nodes.dispatcher.IDuplexDispatcher
-
Removes all duplex output channels from the dispatcher.
- removeAllDuplexOutputChannels() - Method in interface eneter.messaging.nodes.loadbalancer.ILoadBalancer
-
Removes all request receiers from the load balanacer.
- removeDuplexOutputChannel(String) - Method in interface eneter.messaging.nodes.dispatcher.IDuplexDispatcher
-
Removes the duplex output channel from the dispatcher.
- removeDuplexOutputChannel(String) - Method in interface eneter.messaging.nodes.loadbalancer.ILoadBalancer
-
Removes the request receiver from the load balancer.
- Request - Variable in class eneter.messaging.endpoints.rpc.RpcMessage
-
Identifies the type of the request/response message.
- Request - Variable in class eneter.messaging.messagingsystems.composites.messagebus.MessageBusMessage
-
Request for the message bus.
- Request - Variable in class eneter.messaging.nodes.broker.BrokerMessage
-
Type of the request.
- requestReceived() - Method in interface eneter.messaging.endpoints.stringmessages.IDuplexStringMessageReceiver
-
The event is raised when a text message is received.
- responseMessageReceived() - Method in interface eneter.messaging.messagingsystems.messagingsystembase.IDuplexOutputChannel
-
The event is raised when a response message was received.
- responseReceived() - Method in interface eneter.messaging.endpoints.stringmessages.IDuplexStringMessageSender
-
The event is raised when a response message is received.
- responseReceived() - Method in interface eneter.messaging.endpoints.typedmessages.IDuplexTypedMessageSender
-
Raised when a response message is received.
- responseReceiverConnected() - Method in interface eneter.messaging.endpoints.rpc.IRpcService
-
Event raised when a client connected the service.
- responseReceiverConnected() - Method in interface eneter.messaging.endpoints.stringmessages.IDuplexStringMessageReceiver
-
The event is raised when a duplex string message sender opened the connection.
- responseReceiverConnected() - Method in interface eneter.messaging.endpoints.typedmessages.IDuplexTypedMessageReceiver
-
Raised when a new client is connected.
- responseReceiverConnected() - Method in interface eneter.messaging.endpoints.typedmessages.IMultiTypedMessageReceiver
-
Raised when a new client is connected.
- responseReceiverConnected() - Method in interface eneter.messaging.messagingsystems.messagingsystembase.IDuplexInputChannel
-
The event is raised when an output channel opened the connection.
- responseReceiverConnected() - Method in interface eneter.messaging.nodes.channelwrapper.IDuplexChannelUnwrapper
-
The event is invoked when the duplex channel wrapper opened the connection with this unwrapper via its duplex output channel.
- responseReceiverConnected() - Method in interface eneter.messaging.nodes.loadbalancer.ILoadBalancer
-
The event is invoked when the client sending requests was connected to the load balancer.
- responseReceiverDisconnected() - Method in interface eneter.messaging.endpoints.rpc.IRpcService
-
Event raised when a client got disconnected from the service.
- responseReceiverDisconnected() - Method in interface eneter.messaging.endpoints.stringmessages.IDuplexStringMessageReceiver
-
The event is raised when a duplex string message sender closed the connection.
- responseReceiverDisconnected() - Method in interface eneter.messaging.endpoints.typedmessages.IDuplexTypedMessageReceiver
-
Raised when a client closed the connection.
- responseReceiverDisconnected() - Method in interface eneter.messaging.endpoints.typedmessages.IMultiTypedMessageReceiver
-
Raised when a client closed the connection.
- responseReceiverDisconnected() - Method in interface eneter.messaging.messagingsystems.messagingsystembase.IDuplexInputChannel
-
The event is raised when an output channel closed the connection.
- responseReceiverDisconnected() - Method in interface eneter.messaging.nodes.channelwrapper.IDuplexChannelUnwrapper
-
The event is invoked when the duplex channel wrapper closed the connection with this unwrapper via its duplex output channel.
- responseReceiverDisconnected() - Method in interface eneter.messaging.nodes.loadbalancer.ILoadBalancer
-
The event is invoked when the client sending requests was disconnected from the load balanacer.
- ResponseReceiverEventArgs - Class in eneter.messaging.messagingsystems.messagingsystembase
-
Event argument used by the input channel to indicate the output channel was connected or disconnected.
- ResponseReceiverEventArgs(String, String) - Constructor for class eneter.messaging.messagingsystems.messagingsystembase.ResponseReceiverEventArgs
-
Constructs the event from the input parameters.
- ResponseReceiverId - Variable in class eneter.messaging.messagingsystems.connectionprotocols.ProtocolMessage
-
Client id.
- responseReceiverOffline() - Method in interface eneter.messaging.messagingsystems.composites.bufferedmessagingcomposit.IBufferedDuplexInputChannel
-
The event is raised when a response receiver gets into the offline state.
- responseReceiverOnline() - Method in interface eneter.messaging.messagingsystems.composites.bufferedmessagingcomposit.IBufferedDuplexInputChannel
-
The event is raised when a response receiver gets into the online state.
- RoundRobinBalancerFactory - Class in eneter.messaging.nodes.loadbalancer
-
Implements factory to create the load balancer based on Round-Robin algorithm.
- RoundRobinBalancerFactory(IMessagingSystemFactory) - Constructor for class eneter.messaging.nodes.loadbalancer.RoundRobinBalancerFactory
-
Constructs the factory.
- RpcCustomSerializer - Class in eneter.messaging.endpoints.rpc
-
Serializer optimized for RPC.
- RpcCustomSerializer(ISerializer) - Constructor for class eneter.messaging.endpoints.rpc.RpcCustomSerializer
-
Constructs the serializer.
- RpcException - Exception in eneter.messaging.endpoints.rpc
-
Exception thrown if an RPC call fails on the service side.
- RpcException(String, String, String) - Constructor for exception eneter.messaging.endpoints.rpc.RpcException
-
Constructs the exception.
- RpcFactory - Class in eneter.messaging.endpoints.rpc
-
Creates services and clients that can communicate using RPC (Remote Procedure Calls).
- RpcFactory() - Constructor for class eneter.messaging.endpoints.rpc.RpcFactory
-
- RpcFactory(ISerializer) - Constructor for class eneter.messaging.endpoints.rpc.RpcFactory
-
Constructs RpcFactory with specified serializer.
- RpcMessage - Class in eneter.messaging.endpoints.rpc
-
Internal message used for the communication between RpcClient and RpcService.
- RpcMessage() - Constructor for class eneter.messaging.endpoints.rpc.RpcMessage
-
- RsaDigitalSignatureSerializer - Class in eneter.messaging.dataprocessing.serializing
-
Serializer digitaly signing data.
- RsaDigitalSignatureSerializer(X509Certificate, RSAPrivateKey) - Constructor for class eneter.messaging.dataprocessing.serializing.RsaDigitalSignatureSerializer
-
Constructs serializer with default parameters.
- RsaDigitalSignatureSerializer(X509Certificate, RSAPrivateKey, IFunction1<Boolean, X509Certificate>, ISerializer) - Constructor for class eneter.messaging.dataprocessing.serializing.RsaDigitalSignatureSerializer
-
Constructs serializer with custom parameters.
- RsaSerializer - Class in eneter.messaging.dataprocessing.serializing
-
Serializer using RSA.
- RsaSerializer(RSAPublicKey, RSAPrivateKey) - Constructor for class eneter.messaging.dataprocessing.serializing.RsaSerializer
-
Constructs the RSA serializer with default paraneters.
- RsaSerializer(RSAPublicKey, RSAPrivateKey, int, ISerializer) - Constructor for class eneter.messaging.dataprocessing.serializing.RsaSerializer
-
Constructs the RSA serializer with custom parameters.