diff --git a/examples/websocket/streaming/streaming_producer_client.py b/examples/websocket/streaming/streaming_producer_client.py
index ace75460..809b4079 100644
--- a/examples/websocket/streaming/streaming_producer_client.py
+++ b/examples/websocket/streaming/streaming_producer_client.py
@@ -47,7 +47,7 @@ class RandomByteStreamProducer:
       self.paused = False
 
       if not self.started:
-         self.proto.beginMessage(opcode = WebSocketProtocol.MESSAGE_TYPE_BINARY)
+         self.proto.beginMessage(binary = True)
          self.proto.beginMessageFrame(FRAME_SIZE)
          self.started = True