Interface IComponentFiber
public interface IComponentFiber : IDisposable
- Inherited Members
Properties
EntityID
string EntityID { get; }
Property Value
EntityType
string EntityType { get; }
Property Value
IsConnected
bool IsConnected { get; }
Property Value
QuantumSpace
string QuantumSpace { get; }
Property Value
Methods
BroadcastCallAsync<TResp>(string, string, FiberEncapsulatedMsg, CancellationToken, TimeSpan?, string)
ValueTask<IEnumerable<FiberEncapsulatedMsg>> BroadcastCallAsync<TResp>(string ExchangeName, string RoutingKey, FiberEncapsulatedMsg Message, CancellationToken cancellationToken, TimeSpan? Timeout = null, string AcceptOnlyFromEntityType = null)
Parameters
ExchangeName
stringRoutingKey
stringMessage
FiberEncapsulatedMsgcancellationToken
CancellationTokenTimeout
TimeSpan?AcceptOnlyFromEntityType
string
Returns
- ValueTask<IEnumerable<FiberEncapsulatedMsg>>
Type Parameters
TResp
RegisterConsumer(string, string, string[], bool, QueueTypes, QueueRxAsyncDelegate)
IQueueConsumer RegisterConsumer(string ExchangeName, string QueueName, string[] RoutingKeys, bool IsShared, QueueTypes QueueType, QueueRxAsyncDelegate Callback)
Parameters
ExchangeName
stringQueueName
stringRoutingKeys
string[]IsShared
boolQueueType
QueueTypesCallback
QueueRxAsyncDelegate
Returns
- IQueueConsumer