Fix AMQP lib publish

kibertoad · Jun 26, 2023 · ed53cd2 · ed53cd2
1 parent 0e4ae16
commit ed53cd2
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 9 deletions.
diff --git a/packages/amqp/index.ts b/packages/amqp/index.ts
@@ -6,6 +6,3 @@ export { AbstractAmqpPublisher } from './lib/AbstractAmqpPublisher'
 
 export type { AmqpConfig } from './lib/amqpConnectionResolver'
 export { resolveAmqpConnection } from './lib/amqpConnectionResolver'
-
-export { objectToBuffer } from '../core/lib/utils/queueUtils'
-export { waitAndRetry } from '../core/lib/utils/waitUtils'
diff --git a/packages/amqp/lib/AbstractAmqpPublisher.ts b/packages/amqp/lib/AbstractAmqpPublisher.ts
@@ -1,6 +1,5 @@
 import type { SyncPublisher } from '@message-queue-toolkit/core'
-
-import { objectToBuffer } from '../../core/lib/utils/queueUtils'
+import { objectToBuffer } from '@message-queue-toolkit/core'
 
 import { AbstractAmqpService } from './AbstractAmqpService'
 

diff --git a/packages/amqp/lib/AbstractAmqpService.ts b/packages/amqp/lib/AbstractAmqpService.ts
@@ -1,10 +1,12 @@
-import type { QueueConsumerDependencies } from '@message-queue-toolkit/core'
+import type {
+  QueueConsumerDependencies,
+  QueueDependencies,
+  QueueOptions,
+} from '@message-queue-toolkit/core'
 import { AbstractQueueService } from '@message-queue-toolkit/core'
 import type { Channel, Connection } from 'amqplib'
 import type { Options } from 'amqplib/properties'
 
-import type { QueueDependencies, QueueOptions } from '../../core/lib/queues/AbstractQueueService'
-
 export type AMQPDependencies = QueueDependencies & {
   amqpConnection: Connection
 }

diff --git a/packages/amqp/package.json b/packages/amqp/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@message-queue-toolkit/amqp",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "private": false,
   "license": "MIT",
   "description": "AMQP adapter for message-queue-toolkit",