diff --git a/pkg/messaging/adapter.go b/pkg/messaging/adapter.go new file mode 100644 index 0000000..d2c11a5 --- /dev/null +++ b/pkg/messaging/adapter.go @@ -0,0 +1,17 @@ +package messaging + +type MessagingAdapter struct { + messagingChannels *MessagingChannels + adapterChannels *AdapterChannels +} + +func NewMessagingAdapter(messagingChannels *MessagingChannels, adapterChannels *AdapterChannels) *MessagingAdapter { + return &MessagingAdapter{ + messagingChannels: messagingChannels, + adapterChannels: adapterChannels, + } +} + +func (a *MessagingAdapter) Start() error { + return nil +} diff --git a/pkg/messaging/channels.go b/pkg/messaging/channels.go new file mode 100644 index 0000000..b0fa3fa --- /dev/null +++ b/pkg/messaging/channels.go @@ -0,0 +1,7 @@ +package messaging + +type MessagingChannels struct { +} + +type AdapterChannels struct { +} diff --git a/pkg/messaging/entities.go b/pkg/messaging/entities.go new file mode 100644 index 0000000..a8d0b9a --- /dev/null +++ b/pkg/messaging/entities.go @@ -0,0 +1,4 @@ +package messaging + +type Message struct { +}