Browse files

Use endpoint's _create_channel in initialize for listeners

  • Loading branch information...
1 parent 18040ff commit 80c521f0a38bc93d9a994033887317293ea01ff9 @daf daf committed Jan 23, 2013
Showing with 2 additions and 7 deletions.
  1. +2 −7 pyon/net/endpoint.py
View
9 pyon/net/endpoint.py
@@ -506,17 +506,12 @@ def initialize(self, binding=None):
"""
Creates a channel and prepares it for use.
- After this, the endpoint is inthe ready state.
+ After this, the endpoint is in the ready state.
"""
binding = binding or self._binding or self._recv_name.binding
self._ensure_node()
- kwargs = {}
- if isinstance(self._recv_name, BaseTransport):
- kwargs.update({'transport': self._recv_name})
- elif self._transport is not None:
- kwargs.update({'transport': self._transport})
- self._chan = self.node.channel(self.channel_type, **kwargs)
+ self._chan = self._create_channel()
# @TODO this does not feel right
if isinstance(self._recv_name, BaseTransport):

0 comments on commit 80c521f

Please sign in to comment.