README

## 安装

• 通过 composer

$> composer require oncesk/sqs-wrapper dev-master

## 使用

#### 推送（发送）消息

<?php

use SqsWrapper\Manager;
use SqsWrapper\MessageAbstract;

class Message extends MessageAbstract {

	public $test = 1;
	public $array = array(1, 2);
	public $bool = true;
	public $string = 'hello world!';
	public $obj;
}

$client1 = Manager::createClient('KEY', 'SECRET', 'REGION');
$client2 = Manager::createClient('KEY', 'SECRET', \Aws\Common\Enum\Region::IRELAND);
$packer = new \SqsWrapper\Packer();

$manager = new Manager($client, 'Your Queue url');
$manager->setPacker($packer); // set packer for encode and decode message
$msg = new Message();
$msg->obj = new Message();
$msg->obj->string = 'nested object';
$manager->send($msg); // send message to current queue

$manager2 = new Manager($client, 'Your Queue url 2');
$manager2->setPacker($packer);

$collection = new \SqsWrapper\ManagerCollection();
$collection
	->addManager($manager)
	->addManager($manager2);

$msg = new Message();
$msg->obj = new Message();
$msg->obj->string = 'nested object';

$collection->send($msg); // send message in few queues

#### 接收消息

<?php

use SqsWrapper\Manager;
use SqsWrapper\MessageAbstract;

class Message extends MessageAbstract {

	public $test = 1;
	public $array = array(1, 2);
	public $bool = true;
	public $string = 'hello world!';
	public $obj;
}

$client = Manager::createClient('KEY', 'SECRET', \Aws\Common\Enum\Region::IRELAND);

$manager = new Manager($client, 'Your Queue url');
$manager->setPacker(new \SqsWrapper\Packer());

$message = $manager->receive();
print_r($message);  // obj instance of Message