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
ExchangeNamestringRoutingKeystringMessageFiberEncapsulatedMsgcancellationTokenCancellationTokenTimeoutTimeSpan?AcceptOnlyFromEntityTypestring
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
ExchangeNamestringQueueNamestringRoutingKeysstring[]IsSharedboolQueueTypeQueueTypesCallbackQueueRxAsyncDelegate
Returns
- IQueueConsumer