memory_msgsub_manager

Documentation

Index

• type MessageSubscriptionManager
  • func New() *MessageSubscriptionManager
  • func (manager *MessageSubscriptionManager) Consumed(ctx context.Context, msgKey string) error
  • func (manager *MessageSubscriptionManager) Create(ctx context.Context, msgElement sepc_types.Message) (engine_types.MessageSubscription, error)
  • func (manager *MessageSubscriptionManager) FindOneByID(ctx context.Context, msgID string) (engine_types.MessageSubscription, error)

Types

type MessageSubscriptionManager

type MessageSubscriptionManager struct {
	Msgsubs map[string]*msgsub.MessageSubscription `json:"msg_subs"`
}

manager *MessageSubscriptionManager github.com/averyyan/bpmn-engine/bpmn/engine/types.MessageSubscriptionManager

func New

func New() *MessageSubscriptionManager

func (*MessageSubscriptionManager) Consumed

func (manager *MessageSubscriptionManager) Consumed(ctx context.Context, msgKey string) error

消费消息订阅

func (*MessageSubscriptionManager) Create

func (manager *MessageSubscriptionManager) Create(ctx context.Context, msgElement sepc_types.Message) (engine_types.MessageSubscription, error)

创建消费订阅

func (*MessageSubscriptionManager) FindOneByID

func (manager *MessageSubscriptionManager) FindOneByID(ctx context.Context, msgID string) (engine_types.MessageSubscription, error)

通过消息ID找到消息订阅