Format code

Author: minhduc140583

src/init.ts

@@ -6,7 +6,7 @@ import { Attributes, Validator } from 'validator-x';
 import { ApplicationContext } from './context';
 import { HealthController } from './controllers/HealthController';
 import { User } from './models/User';
-import { ActiveMQSender, ActiveMQSubscriber, Config } from './services/activemq';
+import { ActiveMQSubscriber, ActiveMQWriter, Config } from './services/activemq';
 import { ActiveMQChecker } from './services/activemq';
 
 const retries = [5000, 10000, 20000];
@@ -36,16 +36,16 @@ const user: Attributes = {
 
 export function createContext(db: Db, client: Client, config: Config): ApplicationContext {
   const atmqChecker = new ActiveMQChecker(config);
-  const healthController = new HealthController([atmqChecker]);
-  const writer = new MongoInserter(db.collection('users'), 'id');
-  const retryWriter = new RetryWriter(writer.write, retries, writeUser, log);
+  const health = new HealthController([atmqChecker]);
+  const dbwriter = new MongoInserter(db.collection('users'), 'id');
+  const retryWriter = new RetryWriter(dbwriter.write, retries, writeUser, log);
   const errorHandler = new ErrorHandler(log);
   const validator = new Validator<User>(user, true);
-  const consumer = new ActiveMQSubscriber<User>(client, config.destinationName, config.subscriptionName, 'client-individual', true, undefined, undefined, log, log);
-  const producer = new ActiveMQSender<User>(client, config.destinationName, config.subscriptionName);
-  const retryService = new RetryService<User, boolean>(producer.produce, log, log);
+  const subscriber = new ActiveMQSubscriber<User>(client, config.destinationName, config.subscriptionName, 'client-individual', true, undefined, undefined, log, log);
+  const writer = new ActiveMQWriter<User>(client, config.destinationName, config.subscriptionName);
+  const retryService = new RetryService<User, boolean>(writer.write, log, log);
   const handler = new Handler<User, boolean>(retryWriter.write, validator.validate, retries, errorHandler.error, log, log, retryService.retry, 3, 'retry');
-  const ctx: ApplicationContext = { handle: handler.handle, read: consumer.consume, health: healthController };
+  const ctx: ApplicationContext = { handle: handler.handle, read: subscriber.subscribe, health };
   return ctx;
 }
 

src/services/activemq/index.ts

@@ -2,4 +2,4 @@ export * from './config';
 export * from './checker';
 export * from './connection';
 export * from './subscriber';
-export * from './sender';
+export * from './writer';

src/services/activemq/subscriber.ts

@@ -26,10 +26,10 @@ export class ActiveMQSubscriber<T> {
     } else {
       this.retryCountName = retryCountName;
     }
-    this.consume = this.consume.bind(this);
+    this.subscribe = this.subscribe.bind(this);
   }
 
-  consume(handle: (data: T, attributes?: StringMap) => Promise<number>): void {
+  subscribe(handle: (data: T, attributes?: StringMap) => Promise<number>): void {
     const prefix = this.prefix && this.prefix.length > 0 ? this.prefix : '/';
     const subscribeHeaders = {
       'destination': `${this.destinationName}${prefix}${this.subscriptionName}`,

src/services/activemq/sender.ts renamed to src/services/activemq/writer.ts

@@ -2,7 +2,7 @@ import { StringMap } from 'mq-one';
 import Client = require('stompit/lib/Client');
 import { Message } from './message';
 
-export class ActiveMQSender<T> {
+export class ActiveMQWriter<T> {
   constructor(
     private client: Client,
     private destinationName: string,
@@ -11,10 +11,10 @@ export class ActiveMQSender<T> {
     private prefix?: string,
     private log?: (msg: any) => void
   ) {
-    this.produce = this.produce.bind(this);
+    this.write = this.write.bind(this);
   }
 
-  produce(data: T, attributes?: StringMap): Promise<boolean> {
+  write(data: T, attributes?: StringMap): Promise<boolean> {
     const prefix = this.prefix && this.prefix.length > 0 ? this.prefix : '/';
     const sendHeaders = {
       'destination': `${this.destinationName}${prefix}${this.subscriptionName}`,