Documentation ¶
Index ¶
- type Transport
- func (t *Transport) MessageReceived(eventChannel chan *servicebus.IncomingMessageContext) chan *servicebus.IncomingMessageContext
- func (t *Transport) Publish(message *servicebus.OutgoingMessageContext) error
- func (t *Transport) RegisterRouting(route string) error
- func (t *Transport) Send(destination string, command *servicebus.OutgoingMessageContext) error
- func (t *Transport) SendLocal(command *servicebus.OutgoingMessageContext) error
- func (t *Transport) Start(endpointName string) error
- func (Transport) UnregisterRouting(route string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Transport ¶
type Transport struct { ConnectionString string Namespace *asb.Namespace QueueManager *asb.QueueManager Queue *asb.Queue QueueEntity *asb.QueueEntity // contains filtered or unexported fields }
func (*Transport) MessageReceived ¶
func (t *Transport) MessageReceived(eventChannel chan *servicebus.IncomingMessageContext) chan *servicebus.IncomingMessageContext
func (*Transport) Publish ¶
func (t *Transport) Publish(message *servicebus.OutgoingMessageContext) error
func (*Transport) RegisterRouting ¶
func (*Transport) Send ¶
func (t *Transport) Send(destination string, command *servicebus.OutgoingMessageContext) error
func (*Transport) SendLocal ¶
func (t *Transport) SendLocal(command *servicebus.OutgoingMessageContext) error
func (Transport) UnregisterRouting ¶
Click to show internal directories.
Click to hide internal directories.