graze / queue

        assertThat($this->factory, is(anInstanceOf('Graze\Queue\Message\MessageFactoryInterface')));

    }

    public function testCreateMessage()

    {

        $message = $this->factory->createMessage('foo');

        assertThat($message, is(anInstanceOf('Graze\Queue\Message\MessageInterface')));

        assertThat($message->getBody(), is(identicalTo('foo')));

        assertThat($message->isValid(), is(identicalTo(true)));

    }

    public function testCreateMessageWithMetadata()

    {

        assertThat($message->getMetadata()->get('bar'), is(identicalTo('baz')));

    }

    public function testCreateMessageWithValidator()

    {

        $message = $this->factory->createMessage('bar', [

            'validator' => function ($msg) {

                return false;

            },

        ]);

        assertThat($message, is(anInstanceOf('Graze\Queue\Message\MessageInterface')));

        assertThat($message->getBody(), is(identicalTo('bar')));

        assertThat($message->isValid(), is(identicalTo(false)));

    }

}