fix(@integration): Transport.TCP -> Transport.AMQP
MODIFY
packages/@integration/src/messaging/client.ts
packages/@integration/src/messaging/client.ts
@@ -18,7 +18,7 @@ import { requestValidator$, t } from '@marblejs/middleware-io';
const ClientToken = createContextToken<MessagingClient>();
const client = messagingClient({
- transport: Transport.TCP,
+ transport: Transport.AMQP,
options: {
host: 'amqp://localhost:5672',
queue: 'test_queue',

fix(@integration): Transport.TCP -> Transport.AMQP