update format

src/index.ts

@@ -1,4 +1,4 @@
-export { connect, syncFile, syncQueue, testQueue } from "./queue";
+export { connect, syncFile, syncQueue, testQueue, count } from "./queue";
 
 export { pause } from "./utils";
 
@@ -8,4 +8,4 @@ export type { ActionMessage, ActionMessageV1, ActionMessageV2 } from "./actionMe
 
 export type { EventMessageV2 } from "./eventMessage";
 
-export type { ConsumerOpts, SyncCallback } from "./types";
+export type { ConsumerOpts, SyncCallback, Counters } from "./types";

src/queue.ts

@@ -6,13 +6,13 @@ export { ActionMessage, ActionMessageV2, ProcessStage } from './actionMessage';
 
 import { ActionMessage, actionMessageV1to2 } from './actionMessage';
 
-import { ConsumerOpts, SyncCallback } from './types';
+import { ConsumerOpts, SyncCallback, Counters } from './types';
 
 import os from 'os';
 
 let connection: any = null;
 let consumer: any = null;
-export const count = {queued : undefined, ack: 0, nack: 0};
+export const count: Counters = {queued : undefined, ack: 0, nack: 0};
 
 async function exitHandler(evtOrExitCodeOrError: number | string | Error) {
   try {

src/types.ts

@@ -19,3 +19,9 @@ export type SyncResult = {
 }
 
 export type SyncCallback = (action: ActionMessageV2 | EventMessageV2) => Promise<SyncResult | boolean>;
+
+export type Counters = {
+  ack: number;
+  nack: number;
+  queued: number | undefined;
+};