Skip to content

Commit de1b933

Browse files
author
Sam Clements
committed
Raise an error when attempting to query over UDP (closes #4)
1 parent c03f6b2 commit de1b933

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

riemann_client/client.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,8 @@ def send_query(self, query):
6666
return self.transport.send(message)
6767

6868
def query(self, query):
69+
if isinstance(self.transport, riemann_client.transport.UDPTransport):
70+
raise Exception('Cannot query the Riemann server over UDP')
6971
response = self.send_query(query)
7072
return [self.create_dict(e) for e in response.events]
7173

0 commit comments

Comments
 (0)