tidal / PEIP

src/ABS/Router/Router.php

Spacing +8 added lines, -8 removed lines

@@ -34,7 +34,7 @@ 
         EVENT_PRE_RESOLVE = 'pre_resolve',

         EVENT_POST_RESOLVE = 'post_resolve',

         EVENT_ERR_RESOLVE = 'err_resolve',

-        HEADER_CHANNEL  = 'CHANNEL',

+        HEADER_CHANNEL = 'CHANNEL',

         HEADER_CHANNEL_NAME = 'CHANNEL_NAME',

         HEADER_CHANNEL_RESOLVER = 'HEADER_CHANNEL_RESOLVER';

 

@@ -48,7 +48,7 @@ 
      * @param \PEIP\INF\Channel\Channel $inputChannel the input channel for the router 

      * @return 

      */

-    public function __construct(\PEIP\INF\Channel\Channel_Resolver $channelResolver, \PEIP\INF\Channel\Channel $inputChannel){

+    public function __construct(\PEIP\INF\Channel\Channel_Resolver $channelResolver, \PEIP\INF\Channel\Channel $inputChannel) {

         $this->channelResolver = $channelResolver;

         $this->setInputChannel($inputChannel);  

     }               

@@ -60,7 +60,7 @@ 
      * @param \PEIP\INF\Channel\Channel_Resolver $channelResolver the channel resolver for the router

      * @return 

      */

-    public function setChannelResolver(\PEIP\INF\Channel\Channel_Resolver $channelResolver){

+    public function setChannelResolver(\PEIP\INF\Channel\Channel_Resolver $channelResolver) {

         $this->doFireEvent(self::EVENT_CHANNEL_RESOLVER_SET, array(self::HEADER_CHANNEL_RESOLVER=>$channelResolver));

         $this->channelResolver = $channelResolver;

         $this->doFireEvent(self::EVENT_CHANNEL_RESOLVER_SET, array(self::HEADER_CHANNEL_RESOLVER=>$channelResolver));

@@ -73,9 +73,9 @@ 
      * @param \PEIP\INF\Message\Message $message the message to reply with

      * @return 

      */

-    protected function doReply(\PEIP\INF\Message\Message $message){  

+    protected function doReply(\PEIP\INF\Message\Message $message) {  

         $channels = (array)$this->selectChannels($message);

-        foreach($channels as $channel){

+        foreach ($channels as $channel) {

             $this->setOutputChannel($this->resolveChannel($channel));

             $this->replyMessage($message); 

         }

@@ -90,12 +90,12 @@ 
      * @param mixed $channel channel-name or instance of \PEIP\INF\Channel\Channel 

      * @return 

      */

-    protected function resolveChannel($channel){

+    protected function resolveChannel($channel) {

         $this->doFireEvent(self::EVENT_PRE_RESOLVE, array(self::HEADER_CHANNEL=>$channel));

-        if(!($channel instanceof \PEIP\INF\Channel\Channel)){

+        if (!($channel instanceof \PEIP\INF\Channel\Channel)) {

             $channelName = $channel;

             $channel = $this->channelResolver->resolveChannelName($channelName);

-            if(!$channel){

+            if (!$channel) {

                 $this->doFireEvent(self::EVENT_ERR_RESOLVE, array(self::HEADER_CHANNEL_NAME=>$channelName));

                 throw new \RuntimeException('Could not resolve Channel : '.$channelName);

             }

src/Autoload/AutoloadPaths.php

Indentation +158 added lines, -158 removed lines

@@ -97,164 +97,164 @@
     // please, dont�t edit these lines manually

     // use Autoload::make() instead

     public static $paths = array (

-  'PEIP\ABS\Aggregator\MessageBarrierHandler' => '/ABS/aggregator/PEIP\ABS\Aggregator\MessageBarrierHandler.php',

-  'PEIP\ABS\Router\Router' => '/ABS/router/PEIP\ABS\Router\Router.php',

-  'PEIP\ABS\Dispatcher\MapDispatcher' => '/ABS/dispatcher/PEIP\ABS\Dispatcher\MapDispatcher.php',

-  'PEIP\ABS\Dispatcher\Dispatcher' => '/ABS/dispatcher/PEIP\ABS\Dispatcher\Dispatcher.php',

-  'PEIP\ABS\Channel\SubscribableChannel' => '/ABS/channel/PEIP\ABS\Channel\SubscribableChannel.php',

-  'PEIP\ABS\Channel\PollableChannel' => '/ABS/channel/PEIP\ABS\Channel\PollableChannel.php',

-  'PEIP\ABS\Channel\Channel' => '/ABS/channel/PEIP\ABS\Channel\Channel.php',

-  'PEIP\ABS\Splitter\MessageSplitter' => '/ABS/splitter/PEIP\ABS\Splitter\MessageSplitter.php',

-  'PEIP\ABS\Pipe\EventPipe' => '/ABS/pipe/PEIP\ABS\Pipe\EventPipe.php',

-  'PEIP\ABS\Handler\MessageHandler' => '/ABS/handler/PEIP\ABS\Handler\MessageHandler.php',

-  'PEIP\ABS\Handler\ReplyProducingMessageHandler' => '/ABS/handler/PEIP\ABS\Handler\ReplyProducingMessageHandler.php',

-  'PEIP\ABS\Handler\DiscardingMessageHandler' => '/ABS/handler/PEIP\ABS\Handler\DiscardingMessageHandler.php',

-  'PEIP\ABS\Command\Command' => '/ABS/command/PEIP\ABS\Command\Command.php',

-  'PEIP\ABS\Transformer\ContentTransformer' => '/ABS/transformer/PEIP\ABS\Transformer\ContentTransformer.php',

-  'PEIP\ABS\Transformer\Transformer' => '/ABS/transformer/PEIP\ABS\Transformer\Transformer.php',

-  'PEIP\ABS\Service\ServiceActivator' => '/ABS/service/PEIP\ABS\Service\ServiceActivator.php',

-  'PEIP\ABS\Base\MutableContainer' => '/ABS/base/PEIP\ABS\Base\MutableContainer.php',

-  'PEIP\ABS\Base\Connectable' => '/ABS/base/PEIP\ABS\Base\Connectable.php',

-  'PEIP\ABS\Base\Container' => '/ABS/base/PEIP\ABS\Base\Container.php',

-  'PEIP\ABS\Request\Connection' => '/ABS/request/PEIP\ABS\Request\Connection.php',

-  'PEIP\ABS\Request\Request' => '/ABS/request/PEIP\ABS\Request\Request.php',

-  'PEIP\ABS\Context\ContextPlugin' => '/ABS/context/PEIP\ABS\Context\ContextPlugin.php',

-  'EventClassDispatcher' => '/dispatcher/EventClassDispatcher.php',

-  'ObjectMapDispatcher' => '/dispatcher/ObjectMapDispatcher.php',

-  'ClassDispatcher' => '/dispatcher/ClassDispatcher.php',

-  'ObjectEventDispatcher' => '/dispatcher/ObjectEventDispatcher.php',

-  'ClassEventDispatcher' => '/dispatcher/ClassEventDispatcher.php',

-  'MapDispatcher' => '/dispatcher/MapDispatcher.php',

-  'Dispatcher' => '/dispatcher/Dispatcher.php',

-  'IteratingDispatcher' => '/dispatcher/IteratingDispatcher.php',

-  'EventBuilder' => '/event/EventBuilder.php',

-  'Event' => '/event/Event.php',

-  'Observable' => '/event/Observable.php',

-  'DirectChannel' => '/channel/DirectChannel.php',

-  'PublishSubscribeChannel' => '/channel/PublishSubscribeChannel.php',

-  'MessageChannel' => '/channel/MessageChannel.php',

-  'ChannelRegistry' => '/channel/ChannelRegistry.php',

-  'QueueChannel' => '/channel/QueueChannel.php',

-  'PollableChannel' => '/channel/PollableChannel.php',

-  'PriorityChannel' => '/channel/PriorityChannel.php',

-  'ChannelAdapter' => '/channel/ChannelAdapter.php',

-  'XMLArrayTranslator' => '/translator/XMLArrayTranslator.php',

-  'SimpleFixedEventPipe' => '/pipe/SimpleFixedEventPipe.php',

-  'Pipe' => '/pipe/Pipe.php',

-  'FixedEventPipe' => '/pipe/FixedEventPipe.php',

-  'Event_Pipe' => '/pipe/Event_Pipe.php',

-  'SimpleEventPipe' => '/pipe/SimpleEventPipe.php',

-  'CommandPipe' => '/pipe/CommandPipe.php',

-  'CallableHandler' => '/handler/CallableHandler.php',

-  'Command' => '/command/Command.php',

-  'ParameterHolderCollection' => '/data/ParameterHolderCollection.php',

-  'ParameterCollection' => '/data/ParameterCollection.php',

-  'InternalStoreAbstract' => '/data/InternalStoreAbstract.php',

-  'StoreCollection' => '/data/StoreCollection.php',

-  'Store' => '/data/Store.php',

-  'ArrayAccess' => '/data/ArrayAccess.php',

-  'ParameterHolder' => '/data/ParameterHolder.php',

-  'ServiceContainer' => '/service/ServiceContainer.php',

-  'SplittingServiceActivator' => '/service/SplittingServiceActivator.php',

-  'ServiceActivator' => '/service/ServiceActivator.php',

-  'ServiceContainer_Builder' => '/service/ServiceContainer_Builder.php',

-  'HeaderServiceActivator' => '/service/HeaderServiceActivator.php',

-  'ServiceProvider' => '/service/ServiceProvider.php',

-  'StringServiceActivator' => '/service/StringServiceActivator.php',

-  'ServiceFactory' => '/factory/ServiceFactory.php',

-  'DedicatedFactory' => '/factory/DedicatedFactory.php',

-  'PEIP' => '/PEIP.php',

-  'SimpleMessagingGateway' => '/gateway/SimpleMessagingGateway.php',

-  'PEIP\INF\Aggregator\CompletionStrategy' => '/INF/aggregator/PEIP\INF\Aggregator\CompletionStrategy.php',

-  'PEIP\INF\Aggregator\CorrelationStrategy' => '/INF/aggregator/PEIP\INF\Aggregator\CorrelationStrategy.php',

-  'PEIP\INF\Dispatcher\BreakableDispatcher' => '/INF/dispatcher/PEIP\INF\Dispatcher\BreakableDispatcher.php',

-  'PEIP\INF\Dispatcher\ObjectMapDispatcher' => '/INF/dispatcher/PEIP\INF\Dispatcher\ObjectMapDispatcher.php',

-  'PEIP\INF\Dispatcher\MapDispatcher' => '/INF/dispatcher/PEIP\INF\Dispatcher\MapDispatcher.php',

-  'PEIP\INF\Dispatcher\ListDispatcher' => '/INF/dispatcher/PEIP\INF\Dispatcher\ListDispatcher.php',

-  'PEIP\INF\Dispatcher\Dispatcher' => '/INF/dispatcher/PEIP\INF\Dispatcher\Dispatcher.php',

-  'PEIP\INF\Event\EventHandler' => '/INF/event/PEIP\INF\Event\EventHandler.php',

-  'PEIP\INF\Event\EventDispatcher' => '/INF/event/PEIP\INF\Event\EventDispatcher.php',

-  'PEIP\INF\Event\EventPublisher' => '/INF/event/PEIP\INF\Event\EventPublisher.php',

-  'PEIP\INF\Event\Listener' => '/INF/event/PEIP\INF\Event\Listener.php',

-  'PEIP\INF\Event\Event' => '/INF/event/PEIP\INF\Event\Event.php',

-  'PEIP\INF\Event\Observable' => '/INF/event/PEIP\INF\Event\Observable.php',

-  'PEIP\INF\Event\Connectable' => '/INF/event/PEIP\INF\Event\Connectable.php',

-  'PEIP\INF\Event\Observer' => '/INF/event/PEIP\INF\Event\Observer.php',

-  'PEIP\INF\Channel\ChannelResolver' => '/INF/channel/PEIP\INF\Channel\ChannelResolver.php',

-  'PEIP\INF\Channel\PollableChannel' => '/INF/channel/PEIP\INF\Channel\PollableChannel.php',

-  'PEIP\INF\Channel\Channel' => '/INF/channel/PEIP\INF\Channel\Channel.php',

-  'PEIP\INF\Channel\SubscribableChannel' => '/INF/channel/PEIP\INF\Channel\SubscribableChannel.php',

-  'PEIP\INF\Handler\Handler' => '/INF/handler/PEIP\INF\Handler\Handler.php',

-  'PEIP\INF\Command\Command' => '/INF/command/PEIP\INF\Command\Command.php',

-  'PEIP\INF\Command\ParametricCommand' => '/INF/command/PEIP\INF\Command\ParametricCommand.php',

-  'PEIP\INF\Transformer\Transformer' => '/INF/transformer/PEIP\INF\Transformer\Transformer.php',

-  'PEIP\INF\Data\StoreCollection' => '/INF/data/PEIP\INF\Data\StoreCollection.php',

-  'PEIP\INF\Data\ParameterHolder' => '/INF/data/PEIP\INF\Data\ParameterHolder.php',

-  'PEIP\INF\Data\ParameterHolder_Collection' => '/INF/data/PEIP\INF\Data\ParameterHolder_Collection.php',

-  'PEIP\INF\Data\Store' => '/INF/data/PEIP\INF\Data\Store.php',

-  'PEIP\INF\Service\ServiceContainer' => '/INF/service/PEIP\INF\Service\ServiceContainer.php',

-  'PEIP\INF\Service\ServiceActivator' => '/INF/service/PEIP\INF\Service\ServiceActivator.php',

-  'PEIP\INF\Factory\DedicatedFactory' => '/INF/factory/PEIP\INF\Factory\DedicatedFactory.php',

-  'PEIP\INF\Gateway\MessagingGateway' => '/INF/gateway/PEIP\INF\Gateway\MessagingGateway.php',

-  'PEIP\INF\Selector\MessageSelector' => '/INF/selector/PEIP\INF\Selector\MessageSelector.php',

-  'PEIP\INF\Base\Lifecycle' => '/INF/base/PEIP\INF\Base\Lifecycle.php',

-  'PEIP\INF\Base\SingletonMap' => '/INF/base/PEIP\INF\Base\SingletonMap.php',

-  'PEIP\INF\Base\SingletonArgs' => '/INF/base/PEIP\INF\Base\SingletonArgs.php',

-  'PEIP\INF\Base\Identifier' => '/INF/base/PEIP\INF\Base\Identifier.php',

-  'PEIP\INF\Base\MutableContainer' => '/INF/base/PEIP\INF\Base\MutableContainer.php',

-  'PEIP\INF\Base\Singleton' => '/INF/base/PEIP\INF\Base\Singleton.php',

-  'PEIP\INF\Base\Visitor' => '/INF/base/PEIP\INF\Base\Visitor.php',

-  'PEIP\INF\Base\SingletonMap_Array' => '/INF/base/PEIP\INF\Base\SingletonMap_Array.php',

-  'PEIP\INF\Base\Visitable' => '/INF/base/PEIP\INF\Base\Visitable.php',

-  'PEIP\INF\Base\Plugable' => '/INF/base/PEIP\INF\Base\Plugable.php',

-  'PEIP\INF\Base\Filter' => '/INF/base/PEIP\INF\Base\Filter.php',

-  'PEIP\INF\Base\Document' => '/INF/base/PEIP\INF\Base\Document.php',

-  'PEIP\INF\Base\Container' => '/INF/base/PEIP\INF\Base\Container.php',

-  'PEIP\INF\Base\Unsealer' => '/INF/base/PEIP\INF\Base\Unsealer.php',

-  'PEIP\INF\Base\Buildable' => '/INF/base/PEIP\INF\Base\Buildable.php',

-  'PEIP\INF\Base\Sealer' => '/INF/base/PEIP\INF\Base\Sealer.php',

-  'PEIP\INF\Request\Request' => '/INF/request/PEIP\INF\Request\Request.php',

-  'PEIP\INF\Request\Connection' => '/INF/request/PEIP\INF\Request\Connection.php',

-  'PEIP\INF\Message\MessageHandler' => '/INF/message/PEIP\INF\Message\MessageHandler.php',

-  'PEIP\INF\Message\MessageChannel' => '/INF/message/PEIP\INF\Message\MessageChannel.php',

-  'PEIP\INF\Message\HeaderEnricher' => '/INF/message/PEIP\INF\Message\HeaderEnricher.php',

-  'PEIP\INF\Message\Message' => '/INF/message/PEIP\INF\Message\Message.php',

-  'PEIP\INF\Message\Message_Sender' => '/INF/message/PEIP\INF\Message\Message_Sender.php',

-  'PEIP\INF\Message\Message_Builder' => '/INF/message/PEIP\INF\Message\Message_Builder.php',

-  'PEIP\INF\Message\PollableMessageChannel' => '/INF/message/PEIP\INF\Message\PollableMessageChannel.php',

-  'PEIP\INF\Message\EnvelopeMessage' => '/INF/message/PEIP\INF\Message\EnvelopeMessage.php',

-  'PEIP\INF\Message\StringMessage' => '/INF/message/PEIP\INF\Message\StringMessage.php',

-  'PEIP\INF\Message\Message_Dispatcher' => '/INF/message/PEIP\INF\Message\Message_Dispatcher.php',

-  'PEIP\INF\Message\Message_Receiver' => '/INF/message/PEIP\INF\Message\Message_Receiver.php',

-  'PEIP\INF\Message\Message_Source' => '/INF/message/PEIP\INF\Message\Message_Source.php',

-  'PEIP\INF\Context\ContextPlugin' => '/INF/context/PEIP\INF\Context\ContextPlugin.php',

-  'PEIP\INF\Context\Context' => '/INF/context/PEIP\INF\Context\Context.php',

-  'ContentClassSelector' => '/selector/ContentClassSelector.php',

-  'ContentTypeSelector' => '/selector/ContentTypeSelector.php',

-  'ReflectionPool' => '/util/ReflectionPool.php',

-  'Test' => '/util/Test.php',

-  'Reflection' => '/util/Reflection.php',

-  'VisitableArray' => '/base/VisitableArray.php',

-  'Sealer' => '/base/Sealer.php',

-  'ObjectStorage' => '/base/ObjectStorage.php',

-  'DynamicAdapter' => '/base/DynamicAdapter.php',

-  'GenericBuilder' => '/base/GenericBuilder.php',

-  'Reflection_Class_Builder' => '/base/Reflection_Class_Builder.php',

-  'FlyAdapter' => '/base/FlyAdapter.php',

-  'CallableMessageHandler' => '/message/CallableMessageHandler.php',

-  'TextMessage' => '/message/TextMessage.php',

-  'MessageBuilder' => '/message/MessageBuilder.php',

-  'ErrorMessage' => '/message/ErrorMessage.php',

-  'GenericMessage' => '/message/GenericMessage.php',

-  'Command_Message' => '/message/Command_Message.php',

-  'StringMessage' => '/message/StringMessage.php',

-  'XMLContextReader' => '/context/XMLContextReader.php',

-  'XMLContext' => '/context/XMLContext.php',

-  'BasePlugin' => '/plugins/BasePlugin.php',

-  'SimpleAutoload' => '/autoload/SimpleAutoload.php',

-  'Autoload' => '/autoload/Autoload.php',

-  'AutoloadPaths' => '/autoload/AutoloadPaths.php',

-  'Wiretap' => '/listener/Wiretap.php',

+    'PEIP\ABS\Aggregator\MessageBarrierHandler' => '/ABS/aggregator/PEIP\ABS\Aggregator\MessageBarrierHandler.php',

+    'PEIP\ABS\Router\Router' => '/ABS/router/PEIP\ABS\Router\Router.php',

+    'PEIP\ABS\Dispatcher\MapDispatcher' => '/ABS/dispatcher/PEIP\ABS\Dispatcher\MapDispatcher.php',

+    'PEIP\ABS\Dispatcher\Dispatcher' => '/ABS/dispatcher/PEIP\ABS\Dispatcher\Dispatcher.php',

+    'PEIP\ABS\Channel\SubscribableChannel' => '/ABS/channel/PEIP\ABS\Channel\SubscribableChannel.php',

+    'PEIP\ABS\Channel\PollableChannel' => '/ABS/channel/PEIP\ABS\Channel\PollableChannel.php',

+    'PEIP\ABS\Channel\Channel' => '/ABS/channel/PEIP\ABS\Channel\Channel.php',

+    'PEIP\ABS\Splitter\MessageSplitter' => '/ABS/splitter/PEIP\ABS\Splitter\MessageSplitter.php',

+    'PEIP\ABS\Pipe\EventPipe' => '/ABS/pipe/PEIP\ABS\Pipe\EventPipe.php',

+    'PEIP\ABS\Handler\MessageHandler' => '/ABS/handler/PEIP\ABS\Handler\MessageHandler.php',

+    'PEIP\ABS\Handler\ReplyProducingMessageHandler' => '/ABS/handler/PEIP\ABS\Handler\ReplyProducingMessageHandler.php',

+    'PEIP\ABS\Handler\DiscardingMessageHandler' => '/ABS/handler/PEIP\ABS\Handler\DiscardingMessageHandler.php',

+    'PEIP\ABS\Command\Command' => '/ABS/command/PEIP\ABS\Command\Command.php',

+    'PEIP\ABS\Transformer\ContentTransformer' => '/ABS/transformer/PEIP\ABS\Transformer\ContentTransformer.php',

+    'PEIP\ABS\Transformer\Transformer' => '/ABS/transformer/PEIP\ABS\Transformer\Transformer.php',

+    'PEIP\ABS\Service\ServiceActivator' => '/ABS/service/PEIP\ABS\Service\ServiceActivator.php',

+    'PEIP\ABS\Base\MutableContainer' => '/ABS/base/PEIP\ABS\Base\MutableContainer.php',

+    'PEIP\ABS\Base\Connectable' => '/ABS/base/PEIP\ABS\Base\Connectable.php',

+    'PEIP\ABS\Base\Container' => '/ABS/base/PEIP\ABS\Base\Container.php',

+    'PEIP\ABS\Request\Connection' => '/ABS/request/PEIP\ABS\Request\Connection.php',

+    'PEIP\ABS\Request\Request' => '/ABS/request/PEIP\ABS\Request\Request.php',

+    'PEIP\ABS\Context\ContextPlugin' => '/ABS/context/PEIP\ABS\Context\ContextPlugin.php',

+    'EventClassDispatcher' => '/dispatcher/EventClassDispatcher.php',

+    'ObjectMapDispatcher' => '/dispatcher/ObjectMapDispatcher.php',

+    'ClassDispatcher' => '/dispatcher/ClassDispatcher.php',

+    'ObjectEventDispatcher' => '/dispatcher/ObjectEventDispatcher.php',

+    'ClassEventDispatcher' => '/dispatcher/ClassEventDispatcher.php',

+    'MapDispatcher' => '/dispatcher/MapDispatcher.php',

+    'Dispatcher' => '/dispatcher/Dispatcher.php',

+    'IteratingDispatcher' => '/dispatcher/IteratingDispatcher.php',

+    'EventBuilder' => '/event/EventBuilder.php',

+    'Event' => '/event/Event.php',

+    'Observable' => '/event/Observable.php',

+    'DirectChannel' => '/channel/DirectChannel.php',

+    'PublishSubscribeChannel' => '/channel/PublishSubscribeChannel.php',

+    'MessageChannel' => '/channel/MessageChannel.php',

+    'ChannelRegistry' => '/channel/ChannelRegistry.php',

+    'QueueChannel' => '/channel/QueueChannel.php',

+    'PollableChannel' => '/channel/PollableChannel.php',

+    'PriorityChannel' => '/channel/PriorityChannel.php',

+    'ChannelAdapter' => '/channel/ChannelAdapter.php',

+    'XMLArrayTranslator' => '/translator/XMLArrayTranslator.php',

+    'SimpleFixedEventPipe' => '/pipe/SimpleFixedEventPipe.php',

+    'Pipe' => '/pipe/Pipe.php',

+    'FixedEventPipe' => '/pipe/FixedEventPipe.php',

+    'Event_Pipe' => '/pipe/Event_Pipe.php',

+    'SimpleEventPipe' => '/pipe/SimpleEventPipe.php',

+    'CommandPipe' => '/pipe/CommandPipe.php',

+    'CallableHandler' => '/handler/CallableHandler.php',

+    'Command' => '/command/Command.php',

+    'ParameterHolderCollection' => '/data/ParameterHolderCollection.php',

+    'ParameterCollection' => '/data/ParameterCollection.php',

+    'InternalStoreAbstract' => '/data/InternalStoreAbstract.php',

+    'StoreCollection' => '/data/StoreCollection.php',

+    'Store' => '/data/Store.php',

+    'ArrayAccess' => '/data/ArrayAccess.php',

+    'ParameterHolder' => '/data/ParameterHolder.php',

+    'ServiceContainer' => '/service/ServiceContainer.php',

+    'SplittingServiceActivator' => '/service/SplittingServiceActivator.php',

+    'ServiceActivator' => '/service/ServiceActivator.php',

+    'ServiceContainer_Builder' => '/service/ServiceContainer_Builder.php',

+    'HeaderServiceActivator' => '/service/HeaderServiceActivator.php',

+    'ServiceProvider' => '/service/ServiceProvider.php',

+    'StringServiceActivator' => '/service/StringServiceActivator.php',

+    'ServiceFactory' => '/factory/ServiceFactory.php',

+    'DedicatedFactory' => '/factory/DedicatedFactory.php',

+    'PEIP' => '/PEIP.php',

+    'SimpleMessagingGateway' => '/gateway/SimpleMessagingGateway.php',

+    'PEIP\INF\Aggregator\CompletionStrategy' => '/INF/aggregator/PEIP\INF\Aggregator\CompletionStrategy.php',

+    'PEIP\INF\Aggregator\CorrelationStrategy' => '/INF/aggregator/PEIP\INF\Aggregator\CorrelationStrategy.php',

+    'PEIP\INF\Dispatcher\BreakableDispatcher' => '/INF/dispatcher/PEIP\INF\Dispatcher\BreakableDispatcher.php',

+    'PEIP\INF\Dispatcher\ObjectMapDispatcher' => '/INF/dispatcher/PEIP\INF\Dispatcher\ObjectMapDispatcher.php',

+    'PEIP\INF\Dispatcher\MapDispatcher' => '/INF/dispatcher/PEIP\INF\Dispatcher\MapDispatcher.php',

+    'PEIP\INF\Dispatcher\ListDispatcher' => '/INF/dispatcher/PEIP\INF\Dispatcher\ListDispatcher.php',

+    'PEIP\INF\Dispatcher\Dispatcher' => '/INF/dispatcher/PEIP\INF\Dispatcher\Dispatcher.php',

+    'PEIP\INF\Event\EventHandler' => '/INF/event/PEIP\INF\Event\EventHandler.php',

+    'PEIP\INF\Event\EventDispatcher' => '/INF/event/PEIP\INF\Event\EventDispatcher.php',

+    'PEIP\INF\Event\EventPublisher' => '/INF/event/PEIP\INF\Event\EventPublisher.php',

+    'PEIP\INF\Event\Listener' => '/INF/event/PEIP\INF\Event\Listener.php',

+    'PEIP\INF\Event\Event' => '/INF/event/PEIP\INF\Event\Event.php',

+    'PEIP\INF\Event\Observable' => '/INF/event/PEIP\INF\Event\Observable.php',

+    'PEIP\INF\Event\Connectable' => '/INF/event/PEIP\INF\Event\Connectable.php',

+    'PEIP\INF\Event\Observer' => '/INF/event/PEIP\INF\Event\Observer.php',

+    'PEIP\INF\Channel\ChannelResolver' => '/INF/channel/PEIP\INF\Channel\ChannelResolver.php',

+    'PEIP\INF\Channel\PollableChannel' => '/INF/channel/PEIP\INF\Channel\PollableChannel.php',

+    'PEIP\INF\Channel\Channel' => '/INF/channel/PEIP\INF\Channel\Channel.php',

+    'PEIP\INF\Channel\SubscribableChannel' => '/INF/channel/PEIP\INF\Channel\SubscribableChannel.php',

+    'PEIP\INF\Handler\Handler' => '/INF/handler/PEIP\INF\Handler\Handler.php',

+    'PEIP\INF\Command\Command' => '/INF/command/PEIP\INF\Command\Command.php',

+    'PEIP\INF\Command\ParametricCommand' => '/INF/command/PEIP\INF\Command\ParametricCommand.php',

+    'PEIP\INF\Transformer\Transformer' => '/INF/transformer/PEIP\INF\Transformer\Transformer.php',

+    'PEIP\INF\Data\StoreCollection' => '/INF/data/PEIP\INF\Data\StoreCollection.php',

+    'PEIP\INF\Data\ParameterHolder' => '/INF/data/PEIP\INF\Data\ParameterHolder.php',

+    'PEIP\INF\Data\ParameterHolder_Collection' => '/INF/data/PEIP\INF\Data\ParameterHolder_Collection.php',

+    'PEIP\INF\Data\Store' => '/INF/data/PEIP\INF\Data\Store.php',

+    'PEIP\INF\Service\ServiceContainer' => '/INF/service/PEIP\INF\Service\ServiceContainer.php',

+    'PEIP\INF\Service\ServiceActivator' => '/INF/service/PEIP\INF\Service\ServiceActivator.php',

+    'PEIP\INF\Factory\DedicatedFactory' => '/INF/factory/PEIP\INF\Factory\DedicatedFactory.php',

+    'PEIP\INF\Gateway\MessagingGateway' => '/INF/gateway/PEIP\INF\Gateway\MessagingGateway.php',

+    'PEIP\INF\Selector\MessageSelector' => '/INF/selector/PEIP\INF\Selector\MessageSelector.php',

+    'PEIP\INF\Base\Lifecycle' => '/INF/base/PEIP\INF\Base\Lifecycle.php',

+    'PEIP\INF\Base\SingletonMap' => '/INF/base/PEIP\INF\Base\SingletonMap.php',

+    'PEIP\INF\Base\SingletonArgs' => '/INF/base/PEIP\INF\Base\SingletonArgs.php',

+    'PEIP\INF\Base\Identifier' => '/INF/base/PEIP\INF\Base\Identifier.php',

+    'PEIP\INF\Base\MutableContainer' => '/INF/base/PEIP\INF\Base\MutableContainer.php',

+    'PEIP\INF\Base\Singleton' => '/INF/base/PEIP\INF\Base\Singleton.php',

+    'PEIP\INF\Base\Visitor' => '/INF/base/PEIP\INF\Base\Visitor.php',

+    'PEIP\INF\Base\SingletonMap_Array' => '/INF/base/PEIP\INF\Base\SingletonMap_Array.php',

+    'PEIP\INF\Base\Visitable' => '/INF/base/PEIP\INF\Base\Visitable.php',

+    'PEIP\INF\Base\Plugable' => '/INF/base/PEIP\INF\Base\Plugable.php',

+    'PEIP\INF\Base\Filter' => '/INF/base/PEIP\INF\Base\Filter.php',

+    'PEIP\INF\Base\Document' => '/INF/base/PEIP\INF\Base\Document.php',

+    'PEIP\INF\Base\Container' => '/INF/base/PEIP\INF\Base\Container.php',

+    'PEIP\INF\Base\Unsealer' => '/INF/base/PEIP\INF\Base\Unsealer.php',

+    'PEIP\INF\Base\Buildable' => '/INF/base/PEIP\INF\Base\Buildable.php',

+    'PEIP\INF\Base\Sealer' => '/INF/base/PEIP\INF\Base\Sealer.php',

+    'PEIP\INF\Request\Request' => '/INF/request/PEIP\INF\Request\Request.php',

+    'PEIP\INF\Request\Connection' => '/INF/request/PEIP\INF\Request\Connection.php',

+    'PEIP\INF\Message\MessageHandler' => '/INF/message/PEIP\INF\Message\MessageHandler.php',

+    'PEIP\INF\Message\MessageChannel' => '/INF/message/PEIP\INF\Message\MessageChannel.php',

+    'PEIP\INF\Message\HeaderEnricher' => '/INF/message/PEIP\INF\Message\HeaderEnricher.php',

+    'PEIP\INF\Message\Message' => '/INF/message/PEIP\INF\Message\Message.php',

+    'PEIP\INF\Message\Message_Sender' => '/INF/message/PEIP\INF\Message\Message_Sender.php',

+    'PEIP\INF\Message\Message_Builder' => '/INF/message/PEIP\INF\Message\Message_Builder.php',

+    'PEIP\INF\Message\PollableMessageChannel' => '/INF/message/PEIP\INF\Message\PollableMessageChannel.php',

+    'PEIP\INF\Message\EnvelopeMessage' => '/INF/message/PEIP\INF\Message\EnvelopeMessage.php',

+    'PEIP\INF\Message\StringMessage' => '/INF/message/PEIP\INF\Message\StringMessage.php',

+    'PEIP\INF\Message\Message_Dispatcher' => '/INF/message/PEIP\INF\Message\Message_Dispatcher.php',

+    'PEIP\INF\Message\Message_Receiver' => '/INF/message/PEIP\INF\Message\Message_Receiver.php',

+    'PEIP\INF\Message\Message_Source' => '/INF/message/PEIP\INF\Message\Message_Source.php',

+    'PEIP\INF\Context\ContextPlugin' => '/INF/context/PEIP\INF\Context\ContextPlugin.php',

+    'PEIP\INF\Context\Context' => '/INF/context/PEIP\INF\Context\Context.php',

+    'ContentClassSelector' => '/selector/ContentClassSelector.php',

+    'ContentTypeSelector' => '/selector/ContentTypeSelector.php',

+    'ReflectionPool' => '/util/ReflectionPool.php',

+    'Test' => '/util/Test.php',

+    'Reflection' => '/util/Reflection.php',

+    'VisitableArray' => '/base/VisitableArray.php',

+    'Sealer' => '/base/Sealer.php',

+    'ObjectStorage' => '/base/ObjectStorage.php',

+    'DynamicAdapter' => '/base/DynamicAdapter.php',

+    'GenericBuilder' => '/base/GenericBuilder.php',

+    'Reflection_Class_Builder' => '/base/Reflection_Class_Builder.php',

+    'FlyAdapter' => '/base/FlyAdapter.php',

+    'CallableMessageHandler' => '/message/CallableMessageHandler.php',

+    'TextMessage' => '/message/TextMessage.php',

+    'MessageBuilder' => '/message/MessageBuilder.php',

+    'ErrorMessage' => '/message/ErrorMessage.php',

+    'GenericMessage' => '/message/GenericMessage.php',

+    'Command_Message' => '/message/Command_Message.php',

+    'StringMessage' => '/message/StringMessage.php',

+    'XMLContextReader' => '/context/XMLContextReader.php',

+    'XMLContext' => '/context/XMLContext.php',

+    'BasePlugin' => '/plugins/BasePlugin.php',

+    'SimpleAutoload' => '/autoload/SimpleAutoload.php',

+    'Autoload' => '/autoload/Autoload.php',

+    'AutoloadPaths' => '/autoload/AutoloadPaths.php',

+    'Wiretap' => '/listener/Wiretap.php',

 );

     

 }

Spacing +1 added lines, -1 removed lines

@@ -96,7 +96,7 @@
 

     // please, dont�t edit these lines manually

     // use Autoload::make() instead

-    public static $paths = array (

+    public static $paths = array(

   'PEIP\ABS\Aggregator\MessageBarrierHandler' => '/ABS/aggregator/PEIP\ABS\Aggregator\MessageBarrierHandler.php',

   'PEIP\ABS\Router\Router' => '/ABS/router/PEIP\ABS\Router\Router.php',

   'PEIP\ABS\Dispatcher\MapDispatcher' => '/ABS/dispatcher/PEIP\ABS\Dispatcher\MapDispatcher.php',

src/Autoload/SimpleAutoload.php

Indentation +2 added lines, -2 removed lines

@@ -149,8 +149,8 @@
      */     

     public function autoload($class){

         $path = str_replace('PEIP\\', '', $class);

-	$path = $this->baseDir.'/'.str_replace('\\', '/', $path).'.php'; 

-	//$path = $this->getClassPath($class);

+    $path = $this->baseDir.'/'.str_replace('\\', '/', $path).'.php'; 

+    //$path = $this->getClassPath($class);

         if (is_file($path)){

             require $path;

                 if(class_exists($class) || interface_exists($class)){

Spacing +17 added lines, -17 removed lines

@@ -33,7 +33,7 @@ 
      * 

      * @access protected

      */             

-    protected function __construct(){

+    protected function __construct() {

         $this->init();

     }   

 

@@ -43,10 +43,10 @@ 
      * 

      * @access protected

      */     

-    protected function init(){

+    protected function init() {

         $this->baseDir = self::getBaseDirectory();

         ini_set('unserialize_callback_func', 'spl_autoload_call');

-        if (false === spl_autoload_register(array($this, 'autoload'))){

+        if (false === spl_autoload_register(array($this, 'autoload'))) {

             throw new \RuntimeException(sprintf('Unable to register %s::autoload as an autoloading method.', get_class($this)));

         }   

     }

@@ -58,7 +58,7 @@ 
      * @access protected

      * @return string the base directory

      */     

-    protected static function getBaseDirectory(){

+    protected static function getBaseDirectory() {

         return str_replace(DIRECTORY_SEPARATOR, '/', realpath(dirname(__FILE__).DIRECTORY_SEPARATOR.'..'));     

     }

         

@@ -69,8 +69,8 @@ 
      * @static

      * @return SimpleAutoload

      */     

-    static public function getInstance(){

-        if (!isset(self::$instance)){

+    static public function getInstance() {

+        if (!isset(self::$instance)) {

             self::$instance = new SimpleAutoload();

         }

         return self::$instance;

@@ -83,8 +83,8 @@ 
      * @access protected

      * @return SimpleAutoload

      */ 

-    protected static function doGetInstance(){

-        return self::$instance = new SimpleAutoload();;   

+    protected static function doGetInstance() {

+        return self::$instance = new SimpleAutoload(); ;   

     }

         

     /**

@@ -95,7 +95,7 @@ 
      * @param string $path the path to the class-file  

      * @return void

      */     

-    public function setClassPath($class, $path){

+    public function setClassPath($class, $path) {

         $this->classPaths[$class] = $path;

     }

 

@@ -106,7 +106,7 @@ 
      * @param array $classPaths class-paths as key(class)/value(path) pairs array

      * @return void

      */     

-    public function setClassPaths(array $classPaths){

+    public function setClassPaths(array $classPaths) {

         $this->classPaths = $classPaths;    

     }   

 

@@ -117,7 +117,7 @@ 
      * @param array $classPaths class-paths as key(class)/value(path) pairs array

      * @return void

      */     

-    public function addClassPaths(array $classPaths){

+    public function addClassPaths(array $classPaths) {

         $this->classPaths = array_merge($this->classPaths, $classPaths);

     }   

     

@@ -129,12 +129,12 @@ 
      * @param string $class the class name

      * @return path to the class-file 

      */     

-    public function getClassPath($class){

-        if (!isset($this->classPaths[$class])){

+    public function getClassPath($class) {

+        if (!isset($this->classPaths[$class])) {

             return null;

         }

         $file = $this->classPaths[$class];

-        if(!is_file($file)){

+        if (!is_file($file)) {

             $file = $this->baseDir.DIRECTORY_SEPARATOR.$file;

         }       

         return $file;

@@ -147,13 +147,13 @@ 
      * @param string $class the class to load

      * @return path to the class-file 

      */     

-    public function autoload($class){

+    public function autoload($class) {

         $path = str_replace('PEIP\\', '', $class);

 	$path = $this->baseDir.'/'.str_replace('\\', '/', $path).'.php'; 

 	//$path = $this->getClassPath($class);

-        if (is_file($path)){

+        if (is_file($path)) {

             require $path;

-                if(class_exists($class) || interface_exists($class)){

+                if (class_exists($class) || interface_exists($class)) {

                     return true;

                 }

             }

src/Message/CommandMessage.php

Spacing +5 added lines, -5 removed lines

@@ -35,8 +35,8 @@ 
      * @param $headers 

      * @return 

      */

-    public function __construct($content, ArrayAccess $headers = NULL){

-        if(!($content instanceof \PEIP\INF\Command\Command) && !is_callable($content)){

+    public function __construct($content, ArrayAccess $headers = NULL) {

+        if (!($content instanceof \PEIP\INF\Command\Command) && !is_callable($content)) {

             throw new \BadArgumentException('Argument 1 for CommandMessage::__construct must be callable or implment \PEIP\INF\Command\Command');

         }

         

@@ -49,10 +49,10 @@ 
      * @access public

      * @return 

      */

-    public function execute(){

-        if(is_callable($this->getContent())){

+    public function execute() {

+        if (is_callable($this->getContent())) {

             return call_user_func($this->getContent());

-        }else{

+        }else {

             return $this->getContent()->execute();

         }

     }

Braces +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
     protected function getMessage($object){

         if($this->channel instanceof \PEIP\INF\Channel\SubscribableChannel){

             return $object; 

-        }else{

+        } else{

             return $object->getContent()->receive();

         }

     }

src/Message/MessageBuilder.php

Spacing +13 added lines, -13 removed lines

@@ -39,7 +39,7 @@ 
      * @access public

      * @param string $messageClass the message-class to build instances for 

      */

-    public function __construct($messageClass = '\PEIP\Message\GenericMessage'){

+    public function __construct($messageClass = '\PEIP\Message\GenericMessage') {

         $this->messageClass = $messageClass;

         $this->factory = DedicatedFactory::getfromCallable(array($messageClass, 'build'));    

     }

@@ -51,7 +51,7 @@ 
      * @param array $headers the headers to set

      * @return MessageBuilder $this

      */

-    public function copyHeaders(array $headers){

+    public function copyHeaders(array $headers) {

         $this->headers = array_merge($this->headers, $headers);

         return $this;       

     }

@@ -63,7 +63,7 @@ 
      * @param array $headers the headers to set

      * @return MessageBuilder $this

      */

-    public function copyHeadersIfAbsent(array $headers){

+    public function copyHeadersIfAbsent(array $headers) {

         $this->headers = array_merge($headers, $this->headers);

         return $this;   

     }

@@ -75,7 +75,7 @@ 
      * @param string $headerName the name of the header

      * @return MessageBuilder $this

      */

-    public function removeHeader($headerName){

+    public function removeHeader($headerName) {

         unset($this->headers[$headerName]);

         return $this;

     }

@@ -88,7 +88,7 @@ 
      * @param mixed $headerValue the value for the header

      * @return MessageBuilder $this 

      */

-    public function setHeader($headerName, $headerValue){

+    public function setHeader($headerName, $headerValue) {

         $this->headers[$headerName] = $headerValue;

         return $this;   

     }

@@ -100,7 +100,7 @@ 
      * @param array $headers the headers to set

      * @return MessageBuilder $this 

      */

-    public function setHeaders(array $headers){

+    public function setHeaders(array $headers) {

         $this->headers = $headers;

         return $this;   

     }

@@ -111,7 +111,7 @@ 
      * @access public

      * @return array the headers for the message to build 

      */

-    public function getHeaders(){

+    public function getHeaders() {

         return $this->headers;

     }  

         

@@ -122,7 +122,7 @@ 
      * @param $arguments 

      * @return 

      */

-    public function build(array $headers = array()){

+    public function build(array $headers = array()) {

         $this->copyHeaders($headers);

         return GenericBuilder::getInstance($this->messageClass)

             ->build(array($this->payload, new \ArrayObject($this->headers)));        

@@ -135,7 +135,7 @@ 
      * @param mixed $payload payload for the message to build 

      * @return MessageBuilder $this 

      */

-    public function setContent($payload){

+    public function setContent($payload) {

         $this->payload = $payload;

         return $this;

     }

@@ -148,7 +148,7 @@ 
      * @param string $messageClass the message class to build from the builder 

      * @return MessageBuilder new instance of MessageBuilder 

      */    

-    public static function getInstance($messageClass = '\PEIP\Message\GenericMessage'){

+    public static function getInstance($messageClass = '\PEIP\Message\GenericMessage') {

         return new  MessageBuilder($messageClass);

     }

   

@@ -160,7 +160,7 @@ 
      * @param \PEIP\INF\Message\Message $message the message to get class to build from the builder 

      * @return MessageBuilder new instance of MessageBuilder 

      */      

-    public static function getInstanceFromMessage(\PEIP\INF\Message\Message $message){

+    public static function getInstanceFromMessage(\PEIP\INF\Message\Message $message) {

         return new MessageBuilder(get_class($message));

     }

    

@@ -170,7 +170,7 @@ 
      * @access public

      * @param string $messageClass the message-class to build new instances for

      */

-    public function setMessageClass($messageClass){

+    public function setMessageClass($messageClass) {

         $this->messageClass = $messageClass;

     }

  

@@ -180,7 +180,7 @@ 
      * @access public

      * @return string the message-class to build new instances for

      */

-    public function getMessageClass(){

+    public function getMessageClass() {

         return $this->messageClass;

     }         

 }
\ No newline at end of file

src/Message/CallableMessageHandler.php

Spacing +11 added lines, -11 removed lines

@@ -35,7 +35,7 @@ 
      * @param $callable 

      * @return 

      */

-    public function __construct($callable){

+    public function __construct($callable) {

         $this->callable = $callable;    

         $this->examineCallabe();

     }

@@ -45,22 +45,22 @@ 
      * @access protected

      * @return 

      */

-    protected function examineCallabe(){

-        if(is_callable($this->callable)){        

-            if(is_array($this->callable)){

-                list($class, $method) =  $this->callable;

+    protected function examineCallabe() {

+        if (is_callable($this->callable)) {        

+            if (is_array($this->callable)) {

+                list($class, $method) = $this->callable;

                 $static = !is_object($class);

                 $class = is_object($class) ? get_class($class) : (string)$class;

                 $reflectionClass = new \ReflectionClass($class);

                 $reflectionFunc = $reflectionClass->getMethod($method);

-                if($static && !$reflectionFunc->isStatic()){

+                if ($static && !$reflectionFunc->isStatic()) {

                     throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not an Callable: Method "'.$method.'" of class '.$class.' is not static.');                  

                 }

-            }else{

+            }else {

                 $reflectionFunc = new \ReflectionFunction($this->callable);  

             }

             $this->requiredParameters = $reflectionFunc->getNumberOfRequiredParameters();

-        }else{

+        }else {

             throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not a Callable');

         }   

     }   

@@ -73,14 +73,14 @@ 
      * @param $sent 

      * @return 

      */

-    public function handle($message, $channel = false, $sent = false){

-        if(!is_object($message)){

+    public function handle($message, $channel = false, $sent = false) {

+        if (!is_object($message)) {

             throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::handle is not a Object');       

         }   

         try {

             return call_user_func_array($this->callable, array($message, $channel, $sent));

         }

-        catch(\Exception $e){

+        catch (\Exception $e) {

             throw new \RuntimeException('Unable to call Callable: '.$e->getMessage());

         }   

     }   

Braces +3 added lines, -4 removed lines

@@ -56,11 +56,11 @@ 
                 if($static && !$reflectionFunc->isStatic()){

                     throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not an Callable: Method "'.$method.'" of class '.$class.' is not static.');                  

                 }

-            }else{

+            } else{

                 $reflectionFunc = new \ReflectionFunction($this->callable);  

             }

             $this->requiredParameters = $reflectionFunc->getNumberOfRequiredParameters();

-        }else{

+        } else{

             throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not a Callable');

         }   

     }   

@@ -79,8 +79,7 @@ 
         }   

         try {

             return call_user_func_array($this->callable, array($message, $channel, $sent));

-        }

-        catch(\Exception $e){

+        } catch(\Exception $e){

             throw new \RuntimeException('Unable to call Callable: '.$e->getMessage());

         }   

     }   

src/Message/StringMessage.php

Spacing +3 added lines, -3 removed lines

@@ -27,11 +27,11 @@ 
 

     const CONTENT_CAST_TYPE = 'string';

 

-    public function __toString(){

+    public function __toString() {

         return (string)$this->getContent();

     }

 

-    public function getContent(){

+    public function getContent() {

         return (string)parent::getContent();

     }

 

@@ -45,7 +45,7 @@ 
      * @param string $name the name of the header

      * @return boolean wether the header is set

      */     

-    public static function build(array $arguments = array()){

+    public static function build(array $arguments = array()) {

         return GenericBuilder::getInstance(__CLASS__)->build($arguments);

     }

 }
\ No newline at end of file

Doc Comments -1 removed lines

@@ -64,7 +64,6 @@
      * @static

      * @access public

      * @implements \PEIP\INF\Base\Buildable

-     * @param string $name the name of the header

      * @return boolean wether the header is set

      */

     public static function build(array $arguments = array()){

src/Message/ErrorMessage.php

Spacing +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
      * @param $headers 

      * @return 

      */

-    public function __construct(\Exception $payload, array $headers = array()){

+    public function __construct(\Exception $payload, array $headers = array()) {

         $this->payload = $payload;

         $this->headers = $headers;

     }

src/Channel/QueueChannel.php

Spacing +7 added lines, -7 removed lines

@@ -37,7 +37,7 @@ 
      * @param $capacity 

      * @return 

      */

-    public function __construct($capacity = -1){

+    public function __construct($capacity = -1) {

         $this->setCapacity((int)$capacity);

         $this->queue = new SplQueue();  

     }   

@@ -47,7 +47,7 @@ 
      * @access public

      * @return 

      */

-    public function getMessageCount(){

+    public function getMessageCount() {

         return count($this->messages);

     }   

 

@@ -56,7 +56,7 @@ 
      * @access public

      * @return 

      */

-    public function getCapacity(){

+    public function getCapacity() {

         return $this->capacity;

     }       

 

@@ -66,7 +66,7 @@ 
      * @param $capacity 

      * @return 

      */

-    public function setCapacity($capacity){

+    public function setCapacity($capacity) {

         $this->capacity = $capacity;

     }   

 

@@ -76,10 +76,10 @@ 
      * @param $message 

      * @return 

      */

-    protected function doSend(\PEIP\INF\Message\Message $message){

-        if($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()){

+    protected function doSend(\PEIP\INF\Message\Message $message) {

+        if ($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()) {

             $this->queue->enqueque($message);

-        }else{

+        }else {

             throw new \Exception('Not implemented yet.');

         }            

     }       

Braces +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
     protected function getMessage($object){

         if($this->channel instanceof \PEIP\INF\Channel\SubscribableChannel){

             return $object; 

-        }else{

+        } else{

             return $object->getContent()->receive();

         }

     }