use Enqueue\Sqs\SqsConnectionFactory;
public function register()
{
$this->app->singleton(SqsConnectionFactory::class, function () {
return new SqsConnectionFactory("sqs:?key=key&secret=secret®ion=us-east-1&version=latest");
});
}
use Enqueue\Sqs\SqsConnectionFactory;
$application = EcotoneLiteApplication::boostrap(
[
SqsConnectionFactory::class => new SqsConnectionFactory("sqs:?key=key&secret=secret®ion=us-east-1&version=latest")
]
);
We register our SqsConnectionFactory under the class name Enqueue\Sqs\SqsConnectionFactory. This will help Ecotone resolve it automatically, without any additional configuration.
use Ecotone\Sqs\SqsBackedMessageChannelBuilder;
class MessagingConfiguration
{
#[ServiceContext]
public function orderChannel()
{
return SqsBackedMessageChannelBuilder::create("orders");
}
}
Now orders channel will be available in Messaging System.
Message Channel Configuration
SqsBackedMessageChannelBuilder::create("orders")
->withAutoDeclare(false) // do not auto declare queue
->withDefaultTimeToLive(1000) // limit TTL of messages
Message Publisher
If you want to publish Message directly to Exchange, you may use of Publisher.
use Ecotone\Sqs\Configuration\SqsMessagePublisherConfiguration;
class PublisherConfiguration
{
#[ServiceContext]
public function registerPublisherConfig()
{
return
SqsMessagePublisherConfiguration::create(
MessagePublisher::class, // 1
"delivery", // 2
"application/json" // 3
);
}
}
Reference name - Name under which it will be available in Dependency Container.
Queue name - Name of queue where Message should be published
Default Conversion [Optional] - Default type, payload will be converted to.
withAutoDeclareQueueOnSend - should Ecotone try to declare queue before sending message
withHeaderMapper - On default headers are not send with message. You map provide mapping for headers that should be mapped to SQS Message
Message Consumer
To connect consumer directly to a SQS Queue, we need to provide Ecotone with information, how the Queue is configured.
use Ecotone\Sqs\Configuration\SqsMessageConsumerConfiguration;
class ConsumerConfiguration
{
#[ServiceContext]
public function registerConsumerConfig(): array
{
return [
SqsMessageConsumerConfiguration::create("orders_consumer", "orders")
];
}
}
Provides Consumer that will be registered at given name "orders_consumer" and will be polling "orders" queue
Consumer Configuration
$consumerConfiguration = SqsMessageConsumerConfiguration::createDirectExchange()
->withDeclareOnStartup(false) // do not try to declare queue before consuming first message;