We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 04346cd commit cbe7788Copy full SHA for cbe7788
queue.js
@@ -1,5 +1,5 @@
1
-import {EventEmitter} from 'events';
2
-import {queueProxy} from './proxy';
+import { EventEmitter } from 'events';
+import { queueProxy } from './proxy';
3
4
export default class Queue extends EventEmitter {
5
@@ -27,10 +27,10 @@ export default class Queue extends EventEmitter {
27
return new Queue(path);
28
}
29
30
- static connectToRemoteQueue(path) {
31
- queueProxy.connectRemote(path, true);
32
- return new Queue(path);
33
- }
+ static connectToRemoteQueue(path) {
+ queueProxy.connectRemote(path, true);
+ return new Queue(path);
+ }
34
35
startReceiving() {
36
if (this.receiving) {
0 commit comments