import logging
from netdef.Interfaces.DefaultInterface import DefaultInterface
from netdef.Sources import BaseSource, Sources
log = logging.getLogger(__name__)
log.debug("Loading module")
[docs]@Sources.register("ZmqDataAccessSource")
class ZmqDataAccessSource(BaseSource.BaseSource):
def __init__(self, *args, **kwargs):
super().__init__(*args, **kwargs)
log.debug("init %s", self.key)
self.interface = DefaultInterface
[docs] def unpack_address(self):
return self.key
[docs] def pack_address(self, addr):
return addr