mirror of https://github.com/apache/nifi.git
parent
e5925ff4b3
commit
63a0d0c211
|
@ -389,6 +389,7 @@ public class HandleHttpRequest extends AbstractProcessor {
|
||||||
// Right now, that information, though, is only in the ProcessSession, not the ProcessContext,
|
// Right now, that information, though, is only in the ProcessSession, not the ProcessContext,
|
||||||
// so it is not known to us. Should see if it can be added to the ProcessContext.
|
// so it is not known to us. Should see if it can be added to the ProcessContext.
|
||||||
final AsyncContext async = baseRequest.startAsync();
|
final AsyncContext async = baseRequest.startAsync();
|
||||||
|
async.setTimeout(Long.MAX_VALUE); // timeout is handled by HttpContextMap
|
||||||
final boolean added = containerQueue.offer(new HttpRequestContainer(request, response, async));
|
final boolean added = containerQueue.offer(new HttpRequestContainer(request, response, async));
|
||||||
|
|
||||||
if (added) {
|
if (added) {
|
||||||
|
|
Loading…
Reference in New Issue