@@ -80,7 +80,6 @@ |
||
| 80 | 80 | * |
| 81 | 81 | * @access public |
| 82 | 82 | * @param string $name name of the event |
| 83 | - * @param Callable|PEIP\INF\Handler\Handler $listener listener to connect |
|
| 84 | 83 | * @return |
| 85 | 84 | */ |
| 86 | 85 | public function disconnectAll($name){
|
@@ -54,7 +54,7 @@ |
||
| 54 | 54 | * @see PEIP\ABS\Handler\MessageHandler::doSetInputChannel |
| 55 | 55 | * @access public |
| 56 | 56 | * @param \PEIP\INF\Channel\Channel $inputChannel the input-channel |
| 57 | - * @return PEIP\ABS\Handler\MessageHandler $this; |
|
| 57 | + * @return MessageHandler $this; |
|
| 58 | 58 | */ |
| 59 | 59 | public function setInputChannel(\PEIP\INF\Channel\Channel $inputChannel){
|
| 60 | 60 | $this->doSetInputChannel($inputChannel); |
@@ -77,7 +77,7 @@ |
||
| 77 | 77 | $this->inputChannel = $inputChannel; |
| 78 | 78 | if($this->inputChannel instanceof \PEIP\INF\Channel\SubscribableChannel){
|
| 79 | 79 | $this->inputChannel->subscribe($this); |
| 80 | - }else{
|
|
| 80 | + } else{
|
|
| 81 | 81 | $this->unwrapEvents = true; |
| 82 | 82 | $this->inputChannel->connect('postSend', $this);
|
| 83 | 83 | } |
@@ -53,7 +53,7 @@ discard block |
||
| 53 | 53 | * Connects the handler to the output-channel. |
| 54 | 54 | * |
| 55 | 55 | * @access protected |
| 56 | - * @param \PEIP\INF\Channel\Channel $inputChannel the output-channel to connect the handler to |
|
| 56 | + * @param \PEIP\INF\Channel\Channel $outputChannel the output-channel to connect the handler to |
|
| 57 | 57 | * @return |
| 58 | 58 | */ |
| 59 | 59 | protected function doSetOutputChannel(\PEIP\INF\Channel\Channel $outputChannel){
|
@@ -162,7 +162,7 @@ discard block |
||
| 162 | 162 | * |
| 163 | 163 | * @access public |
| 164 | 164 | * @param string $messageClass name of the message-class to create reply-messages from. |
| 165 | - * @return PEIP\ABS\Handler\ReplyProducingMessageHandler $this |
|
| 165 | + * @return ReplyProducingMessageHandler $this |
|
| 166 | 166 | */ |
| 167 | 167 | public function setMessageClass($messageClass){
|
| 168 | 168 | $this->messageClass = $messageClass; |
@@ -195,7 +195,7 @@ discard block |
||
| 195 | 195 | * |
| 196 | 196 | * @access public |
| 197 | 197 | * @param array $headerNames array of message-header names to look for a reply-channel |
| 198 | - * @return PEIP\ABS\Handler\ReplyProducingMessageHandler $this |
|
| 198 | + * @return ReplyProducingMessageHandler $this |
|
| 199 | 199 | */ |
| 200 | 200 | public function setReplyChannelHeaders(array $headerNames){
|
| 201 | 201 | $this->replyChannelHeaders = $headerNames; |
@@ -71,7 +71,6 @@ |
||
| 71 | 71 | * notifies all listeners on a event on a subject |
| 72 | 72 | * |
| 73 | 73 | * @access public |
| 74 | - * @param string $name name of the event |
|
| 75 | 74 | * @param mixed $subject the subject |
| 76 | 75 | * @return |
| 77 | 76 | */ |
@@ -17,7 +17,7 @@ |
||
| 17 | 17 | protected function getMessage($object){
|
| 18 | 18 | if($this->channel instanceof \PEIP\INF\Channel\SubscribableChannel){
|
| 19 | 19 | return $object; |
| 20 | - }else{
|
|
| 20 | + } else{
|
|
| 21 | 21 | return $object->getContent()->receive(); |
| 22 | 22 | } |
| 23 | 23 | } |
@@ -65,7 +65,6 @@ |
||
| 65 | 65 | * Disconnects all listeners. |
| 66 | 66 | * |
| 67 | 67 | * @access public |
| 68 | - * @param Callable|PEIP\INF\Handler\Handler $listener |
|
| 69 | 68 | * @return void |
| 70 | 69 | */ |
| 71 | 70 | public function disconnectAll(){
|
@@ -23,7 +23,7 @@ discard block |
||
| 23 | 23 | * @access public |
| 24 | 24 | * @param string $name name of the event |
| 25 | 25 | * @param \PEIP\INF\Event\Event $object an event object |
| 26 | - * @return boolean |
|
| 26 | + * @return boolean|null |
|
| 27 | 27 | */ |
| 28 | 28 | public function notify($name, $object){
|
| 29 | 29 | if($object instanceof \PEIP\INF\Event\Event){
|
@@ -53,7 +53,7 @@ discard block |
||
| 53 | 53 | * @param array $headers headers of the event-object as key/value pairs |
| 54 | 54 | * @param string $eventClass event-class to create instances from |
| 55 | 55 | * @return |
| 56 | - * @see EventBuilder |
|
| 56 | + boolean|null @see EventBuilder |
|
| 57 | 57 | */ |
| 58 | 58 | public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false){
|
| 59 | 59 | if(!$this->hasListeners($name, ($object))){
|
@@ -70,10 +70,10 @@ |
||
| 70 | 70 | ), |
| 71 | 71 | $object |
| 72 | 72 | ); |
| 73 | - }else{
|
|
| 73 | + } else{
|
|
| 74 | 74 | throw new \InvalidArgumentException('instance of \PEIP\INF\Event\Event must contain subject');
|
| 75 | 75 | } |
| 76 | - }else{
|
|
| 76 | + } else{
|
|
| 77 | 77 | throw new \InvalidArgumentException('object must be instance of \PEIP\INF\Event\Event');
|
| 78 | 78 | } |
| 79 | 79 | } //put your code here |
@@ -38,7 +38,7 @@ |
||
| 38 | 38 | * @access public |
| 39 | 39 | * @param string $name name of the event |
| 40 | 40 | * @param \PEIP\INF\Event\Event $object an event object |
| 41 | - * @return boolean |
|
| 41 | + * @return boolean|null |
|
| 42 | 42 | */ |
| 43 | 43 | public function notify($name, $object){
|
| 44 | 44 | if($object instanceof \PEIP\INF\Event\Event){
|
@@ -70,10 +70,10 @@ |
||
| 70 | 70 | ), |
| 71 | 71 | $object |
| 72 | 72 | ); |
| 73 | - }else{
|
|
| 73 | + } else{
|
|
| 74 | 74 | throw new \InvalidArgumentException('instance of \PEIP\INF\Event\Event must contain subject');
|
| 75 | 75 | } |
| 76 | - }else{
|
|
| 76 | + } else{
|
|
| 77 | 77 | throw new \InvalidArgumentException('object must be instance of \PEIP\INF\Event\Event');
|
| 78 | 78 | } |
| 79 | 79 | } //put your code here |
@@ -162,7 +162,7 @@ discard block |
||
| 162 | 162 | * @access public |
| 163 | 163 | * @param $name |
| 164 | 164 | * @param $subject |
| 165 | - * @return mixed |
|
| 165 | + * @return \PEIP\INF\Handler\Handler |
|
| 166 | 166 | */ |
| 167 | 167 | public function notifyUntil($name, $subject){
|
| 168 | 168 | if($this->hasListeners($name, $subject)){
|
@@ -205,7 +205,7 @@ discard block |
||
| 205 | 205 | * @access protected |
| 206 | 206 | * @param $name |
| 207 | 207 | * @param $object |
| 208 | - * @return boolean |
|
| 208 | + * @return boolean|null |
|
| 209 | 209 | */ |
| 210 | 210 | protected static function doNotify(array $listeners, $subject){
|
| 211 | 211 | foreach($listeners as $listener){
|
@@ -104,7 +104,7 @@ discard block |
||
| 104 | 104 | $listners = $this->doGetListeners(); |
| 105 | 105 | if (!$this->hadListeners($name, $object)){
|
| 106 | 106 | $res = false; |
| 107 | - }else{
|
|
| 107 | + } else{
|
|
| 108 | 108 | $listners = $this->doGetListeners(); |
| 109 | 109 | $res = (boolean) count($listners[$object][$name]); |
| 110 | 110 | } |
@@ -211,7 +211,7 @@ discard block |
||
| 211 | 211 | foreach($listeners as $listener){
|
| 212 | 212 | if($listener instanceof \PEIP\INF\Handler\Handler){
|
| 213 | 213 | $listener->handle($subject); |
| 214 | - }elseif(is_callable($listener)){
|
|
| 214 | + } elseif(is_callable($listener)){
|
|
| 215 | 215 | call_user_func($listener, $subject); |
| 216 | 216 | } |
| 217 | 217 | } |
@@ -49,7 +49,6 @@ |
||
| 49 | 49 | * @access public |
| 50 | 50 | * @param mixed $subject the subject for the event |
| 51 | 51 | * @param string $name the name of the event |
| 52 | - * @param array|ArrayAccess $headers the headers for the event |
|
| 53 | 52 | */ |
| 54 | 53 | public function __construct($subject, $name, $parameters = array(), $type = false){
|
| 55 | 54 | parent::__construct($subject, Test::ensureArrayAccess($parameters)); |