Comparing version 9.0.3 to 9.0.4
{ | ||
"name": "smqp", | ||
"version": "9.0.3", | ||
"version": "9.0.4", | ||
"type": "module", | ||
@@ -70,3 +70,3 @@ "description": "Synchronous message queueing package", | ||
"markdown-toc": "^1.2.0", | ||
"mocha": "^10.5.2", | ||
"mocha": "^11.0.1", | ||
"prettier": "^3.2.5", | ||
@@ -73,0 +73,0 @@ "texample": "^0.0.6" |
import { ConsumeOptions } from './types.js'; | ||
import { Queue, Consumer, queueOptions, onMessage, deleteQueueOptions, QueueState } from './Queue.js'; | ||
import { Shovel, Exchange2Exchange, ShovelDestination, shovelOptions } from './Shovel.js'; | ||
import { Shovel, Exchange2Exchange, ShovelDestination, ShovelOptions } from './Shovel.js'; | ||
import { Message, MessageProperties } from './Message.js'; | ||
@@ -86,5 +86,5 @@ import { Exchange, exchangeType, Binding, exchangeOptions, bindingOptions, ExchangeState } from './Exchange.js'; | ||
deleteQueue(queueName: string, options?: deleteQueueOptions): { messageCount: number }; | ||
bindExchange(source: string, destination: string, pattern?: string, options?: shovelOptions): Exchange2Exchange; | ||
bindExchange(source: string, destination: string, pattern?: string, options?: ShovelOptions): Exchange2Exchange; | ||
unbindExchange(source: string, destination: string, pattern?: string): boolean; | ||
createShovel(name: string, source: BrokerShovelSource, destination: ShovelDestination, options?: shovelOptions): Shovel; | ||
createShovel(name: string, source: BrokerShovelSource, destination: ShovelDestination, options?: ShovelOptions): Shovel; | ||
closeShovel(name: string): boolean; | ||
@@ -91,0 +91,0 @@ getShovel(name: string): Shovel; |
import { Broker } from './Broker.js'; | ||
export { Broker }; | ||
export { Message } from './Message.js'; | ||
export { Message, MessageMessage } from './Message.js'; | ||
export { Queue, Consumer } from './Queue.js'; | ||
export { Shovel } from './Shovel.js'; | ||
export { Shovel, ShovelOptions } from './Shovel.js'; | ||
export { Exchange } from './Exchange.js'; | ||
@@ -8,0 +8,0 @@ export * from './Errors.js'; |
import { Consumer } from './Queue.js'; | ||
import { Broker } from './Broker.js'; | ||
import { Message } from './Message.js'; | ||
import { Message, MessageMessage } from './Message.js'; | ||
type shovelOptions = { | ||
cloneMessage?: (message: Message) => Message; | ||
export interface ShovelOptions { | ||
cloneMessage?: (message: MessageMessage) => MessageMessage; | ||
[x: string]: any; | ||
}; | ||
} | ||
@@ -31,3 +31,3 @@ export interface ShovelSource { | ||
export class Shovel { | ||
constructor(name: string, source: ShovelSource, destination: ShovelDestination, options?: shovelOptions); | ||
constructor(name: string, source: ShovelSource, destination: ShovelDestination, options?: ShovelOptions); | ||
name: string; | ||
@@ -34,0 +34,0 @@ source: ShovelSource; |
126322