def createClient(self):
server = self.config.get('<STR_LIT>', '<STR_LIT:127.0.0.1>')<EOL>port = self.config.get('<STR_LIT:port>', <NUM_LIT>)<EOL>def connect(ip):<EOL><INDENT>self.protocol = riemann.RiemannUDP(ip, port)<EOL>self.endpoint = reactor.listenUDP(<NUM_LIT:0>, self.protocol)<EOL><DEDENT>d = reactor.resolve(server)<EOL>d.addCallback(connect)<EOL>return d<EOL>
Create a UDP connection to Riemann