$r->websocket('/bus' => sub {
			my $self = shift;
			$self->inactivity_timeout(1000);
			#$log->debug(sprintf 'Client connected: %s', $self->tx);
			my $id = sprintf "%s", $self->tx;
			$clients->{$id} = $self->tx;
			$self->on(message => sub {
				my ($self, $msg) = @_;
				for (keys %$clients) {
					$clients->{$_}->send({json => {message => $msg}});
				}
			});

			$self->on(finish => sub {
				#$log->debug('Client disconnected');
				delete $clients->{$id};
				Mojo::IOLoop->timer(10 => sub {
					my $loop = shift;
					if (not scalar keys %{ $clients }) {
						#$log->debug('No clients! exiting!');
						exit;
					} else {
						#$log->debug('Have clients! not exiting!');
					}
				});
			});
		}
	);