incomingJpeg = new byte[bytesToRecieve];
}
}
+ } else {
+ // 401 errors already handled in pipeline by MyNettyAuthHandler.java
+ return;
}
}
if (msg instanceof HttpContent) {
- if (mjpegUri.equals(requestUrl)) {
+ HttpContent content = (HttpContent) msg;
+ if (mjpegUri.equals(requestUrl) && !(content instanceof LastHttpContent)) {
// multiple MJPEG stream packets come back as this.
- HttpContent content = (HttpContent) msg;
byte[] chunkedFrame = new byte[content.content().readableBytes()];
content.content().getBytes(content.content().readerIndex(), chunkedFrame);
CameraServlet localServlet = servlet;
localServlet.openStreams.queueFrame(chunkedFrame);
}
} else {
- HttpContent content = (HttpContent) msg;
// Found some cameras use Content-Type: image/jpg instead of image/jpeg
if (contentType.contains("image/jp")) {
for (int i = 0; i < content.content().capacity(); i++) {