protected class HTTP2ServerConnectionFactory.HTTPServerSessionListener extends ServerSessionListener.Adapter implements Stream.Listener
Stream.Listener.Adapter
ServerSessionListener.Adapter
Constructor and Description |
---|
HTTPServerSessionListener(Connector connector,
EndPoint endPoint) |
Modifier and Type | Method and Description |
---|---|
protected HTTP2ServerConnection |
getConnection() |
void |
onClose(Session session,
GoAwayFrame frame)
Callback method invoked when a GOAWAY frame has been received.
|
void |
onData(Stream stream,
DataFrame frame,
Callback callback)
Callback method invoked when a DATA frame has been received.
|
void |
onFailure(Session session,
Throwable failure)
Callback method invoked when a failure has been detected for this session.
|
void |
onHeaders(Stream stream,
HeadersFrame frame)
Callback method invoked when a HEADERS frame representing the HTTP response has been received.
|
boolean |
onIdleTimeout(Session session)
Callback method invoked when the idle timeout expired.
|
boolean |
onIdleTimeout(Stream stream,
Throwable x)
Callback method invoked when the stream exceeds its idle timeout.
|
Stream.Listener |
onNewStream(Stream stream,
HeadersFrame frame)
Callback method invoked when a new stream is being created upon
receiving a HEADERS frame representing a HTTP request.
|
Map<Integer,Integer> |
onPreface(Session session)
Callback method invoked:
|
Stream.Listener |
onPush(Stream stream,
PushPromiseFrame frame)
Callback method invoked when a PUSH_PROMISE frame has been received.
|
void |
onReset(Stream stream,
ResetFrame frame)
Callback method invoked when a RST_STREAM frame has been received for this stream.
|
onAccept
onPing, onReset, onSettings
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onTimeout
onPing, onReset, onSettings
protected HTTP2ServerConnection getConnection()
public Map<Integer,Integer> onPreface(Session session)
Session.Listener
Callback method invoked:
onPreface
in interface Session.Listener
onPreface
in class Session.Listener.Adapter
session
- the sessionpublic Stream.Listener onNewStream(Stream stream, HeadersFrame frame)
Session.Listener
Callback method invoked when a new stream is being created upon receiving a HEADERS frame representing a HTTP request.
Applications should implement this method to process HTTP requests,
typically providing a HTTP response via
Stream.headers(HeadersFrame, Callback)
.
Applications can detect whether request DATA frames will be arriving
by testing HeadersFrame.isEndStream()
. If the application is
interested in processing the DATA frames, it must return a
Stream.Listener
implementation that overrides
Stream.Listener.onData(Stream, DataFrame, Callback)
.
onNewStream
in interface Session.Listener
onNewStream
in class Session.Listener.Adapter
stream
- the newly created streamframe
- the HEADERS frame receivedStream.Listener
that will be notified of stream eventspublic boolean onIdleTimeout(Session session)
Session.Listener
Callback method invoked when the idle timeout expired.
onIdleTimeout
in interface Session.Listener
onIdleTimeout
in class Session.Listener.Adapter
session
- the sessionpublic void onClose(Session session, GoAwayFrame frame)
Session.Listener
Callback method invoked when a GOAWAY frame has been received.
onClose
in interface Session.Listener
onClose
in class Session.Listener.Adapter
session
- the sessionframe
- the GOAWAY frame receivedpublic void onFailure(Session session, Throwable failure)
Session.Listener
Callback method invoked when a failure has been detected for this session.
onFailure
in interface Session.Listener
onFailure
in class Session.Listener.Adapter
session
- the sessionfailure
- the failurepublic void onHeaders(Stream stream, HeadersFrame frame)
Stream.Listener
Callback method invoked when a HEADERS frame representing the HTTP response has been received.
onHeaders
in interface Stream.Listener
stream
- the streamframe
- the HEADERS frame receivedpublic Stream.Listener onPush(Stream stream, PushPromiseFrame frame)
Stream.Listener
Callback method invoked when a PUSH_PROMISE frame has been received.
onPush
in interface Stream.Listener
stream
- the streamframe
- the PUSH_PROMISE frame receivedpublic void onData(Stream stream, DataFrame frame, Callback callback)
Stream.Listener
Callback method invoked when a DATA frame has been received.
onData
in interface Stream.Listener
stream
- the streamframe
- the DATA frame receivedcallback
- the callback to complete when the bytes of the DATA frame have been consumedpublic void onReset(Stream stream, ResetFrame frame)
Stream.Listener
Callback method invoked when a RST_STREAM frame has been received for this stream.
onReset
in interface Stream.Listener
stream
- the streamframe
- the RST_FRAME receivedSession.Listener.onReset(Session, ResetFrame)
public boolean onIdleTimeout(Stream stream, Throwable x)
Stream.Listener
Callback method invoked when the stream exceeds its idle timeout.
onIdleTimeout
in interface Stream.Listener
stream
- the streamx
- the timeout failureStream.getIdleTimeout()
Copyright © 1995–2017 Webtide. All rights reserved.