+ warn "<<<< _on_read ",dump( $id, $data );
+
+ $data = $self->{message}->{$id} .= $data;
+ my ($magic, $type, $len) = unpack( "a4NN", $data );
+
+ if ( substr($data,0,1) ne "\x00" ) {
+ return if $data !~ s/\.[\n\r]$//s;
+ } elsif ( length $data < $len ) {
+ warn "# _on_read incomplete message";
+ return;
+ }
+
+ warn "#### data ",dump($data);
+