# createMicroservice

### **Importing** <a href="#importing" id="importing"></a>

```typescript
import { createMicroservice } from '@marblejs/messaging';
```

### **Type declaration**

```haskell
createMicroservice :: CreateMicroserviceConfig
    -> Promise<ServerIO<TransportLayerConnection>>
```

### **Parameters**

| *parameter* | definition                 |
| ----------- | -------------------------- |
| *config*    | `CreateMicroserviceConfig` |

####

#### ***CreateMicroserviceConfig***

| ***parameter*** | definition                                |
| --------------- | ----------------------------------------- |
| *listener*      | `MessagingListener`                       |
| *event$*        | \<optional> `HttpServerEffect`            |
| *dependencies*  | \<optional> `Array<BoundDependency<any>>` |
| transport       | `Transport`                               |
| options         | `StrategyOptions`                         |

#### ***StrategyOptions (**`Transport.AMQP`**)***

| *parameter*     | definition                                                                                                                      |
| --------------- | ------------------------------------------------------------------------------------------------------------------------------- |
| *host*          | `string`                                                                                                                        |
| *queue*         | `string`                                                                                                                        |
| *queueOptions*  | \<optional> `Options.AssertQueue` (see: [amqplib](https://www.squaremobius.net/amqp.node/channel_api.html#channel_assertQueue)) |
| *prefetchCount* | \<optional> `number` (defaults to **1**)                                                                                        |
| *expectAck*     | \<optional> boolean                                                                                                             |
| *timeout*       | \<optional> `number` in ms (defaults to **120s**)                                                                               |

#### ***StrategyOptions (**`Transport.REDIS`**)***

| *parameter* | definition                                        |
| ----------- | ------------------------------------------------- |
| *host*      | `string`                                          |
| *channel*   | `string`                                          |
| port        | \<optional> `number`                              |
| *password*  | \<optional> `string`                              |
| *timeout*   | \<optional> `number` in ms (defaults to **120s**) |

### Example (AMQP):

```typescript
import { IO } from 'fp-ts/lib/IO';
import { createMicroservice, messagingListener, Transport } from '@marblejs/messaging';

const amqpMicroservice = createMicroservice({
  transport: Transport.AMQP,
  options: {
    host: 'amqp://localhost:5672',
    queue: 'some_queue_name',
    queueOptions: { durable: true },
    timeout: 360 * 1000,
  },
  listener: messagingListener(...),
  dependencies: [...],
});

const main: IO<void> = async () =>
  (await amqpMicroservice)()

main();
```

### Example (REDIS):

```typescript
import { IO } from 'fp-ts/lib/IO';
import { createMicroservice, messagingListener, Transport } from '@marblejs/messaging';

const redisMicroservice = createMicroservice({
  transport: Transport.REDIS,
  options: {
    host: 'redis://127.0.0.1:6379',
    channel: 'some_channelname',
    timeout: 360 * 1000,
  },
  listener: messagingListener(...),
  dependencies: [...],
});

const main: IO<void> = async () =>
  (await redisMicroservice)()

main();
```