📄 executorfilter.html
字号:
<a name="318" href="#318">318</a> <a name="319" href="#319">319</a> @Override<a name="320" href="#320">320</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> onPreAdd(<a href="../../../../../org/apache/mina/common/IoFilterChain.html">IoFilterChain</a> parent, String name,<a name="321" href="#321">321</a> <a href="../../../../../org/apache/mina/common/IoFilter.html">NextFilter</a> nextFilter) <strong class="jxr_keyword">throws</strong> Exception {<a name="322" href="#322">322</a> <strong class="jxr_keyword">if</strong> (parent.contains(<strong class="jxr_keyword">this</strong>)) {<a name="323" href="#323">323</a> <strong class="jxr_keyword">throw</strong> <strong class="jxr_keyword">new</strong> IllegalArgumentException(<a name="324" href="#324">324</a> <span class="jxr_string">"You can't add the same filter instance more than once. Create another instance and add it."</span>);<a name="325" href="#325">325</a> }<a name="326" href="#326">326</a> }<a name="327" href="#327">327</a> <a name="328" href="#328">328</a> @Override<a name="329" href="#329">329</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">void</strong> sessionCreated(<a href="../../../../../org/apache/mina/common/IoFilter.html">NextFilter</a> nextFilter, <a href="../../../../../org/apache/mina/common/IoSession.html">IoSession</a> session) {<a name="330" href="#330">330</a> nextFilter.sessionCreated(session);<a name="331" href="#331">331</a> }<a name="332" href="#332">332</a> <a name="333" href="#333">333</a> @Override<a name="334" href="#334">334</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">void</strong> sessionOpened(<a href="../../../../../org/apache/mina/common/IoFilter.html">NextFilter</a> nextFilter, <a href="../../../../../org/apache/mina/common/IoSession.html">IoSession</a> session) {<a name="335" href="#335">335</a> <strong class="jxr_keyword">if</strong> (eventTypes.contains(IoEventType.SESSION_OPENED)) {<a name="336" href="#336">336</a> fireEvent(<strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/mina/common/IoFilterEvent.html">IoFilterEvent</a>(nextFilter, IoEventType.SESSION_OPENED,<a name="337" href="#337">337</a> session, <strong class="jxr_keyword">null</strong>));<a name="338" href="#338">338</a> } <strong class="jxr_keyword">else</strong> {<a name="339" href="#339">339</a> nextFilter.sessionOpened(session);<a name="340" href="#340">340</a> }<a name="341" href="#341">341</a> }<a name="342" href="#342">342</a> <a name="343" href="#343">343</a> @Override<a name="344" href="#344">344</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">void</strong> sessionClosed(<a href="../../../../../org/apache/mina/common/IoFilter.html">NextFilter</a> nextFilter, <a href="../../../../../org/apache/mina/common/IoSession.html">IoSession</a> session) {<a name="345" href="#345">345</a> <strong class="jxr_keyword">if</strong> (eventTypes.contains(IoEventType.SESSION_CLOSED)) {<a name="346" href="#346">346</a> fireEvent(<strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/mina/common/IoFilterEvent.html">IoFilterEvent</a>(nextFilter, IoEventType.SESSION_CLOSED,<a name="347" href="#347">347</a> session, <strong class="jxr_keyword">null</strong>));<a name="348" href="#348">348</a> } <strong class="jxr_keyword">else</strong> {<a name="349" href="#349">349</a> nextFilter.sessionClosed(session);<a name="350" href="#350">350</a> }<a name="351" href="#351">351</a> }<a name="352" href="#352">352</a> <a name="353" href="#353">353</a> @Override<a name="354" href="#354">354</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">void</strong> sessionIdle(<a href="../../../../../org/apache/mina/common/IoFilter.html">NextFilter</a> nextFilter, <a href="../../../../../org/apache/mina/common/IoSession.html">IoSession</a> session,<a name="355" href="#355">355</a> <a href="../../../../../org/apache/mina/common/IdleStatus.html">IdleStatus</a> status) {<a name="356" href="#356">356</a> <strong class="jxr_keyword">if</strong> (eventTypes.contains(IoEventType.SESSION_IDLE)) {<a name="357" href="#357">357</a> fireEvent(<strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/mina/common/IoFilterEvent.html">IoFilterEvent</a>(nextFilter, IoEventType.SESSION_IDLE,<a name="358" href="#358">358</a> session, status));<a name="359" href="#359">359</a> } <strong class="jxr_keyword">else</strong> {<a name="360" href="#360">360</a> nextFilter.sessionIdle(session, status);<a name="361" href="#361">361</a> }<a name="362" href="#362">362</a> }<a name="363" href="#363">363</a> <a name="364" href="#364">364</a> @Override<a name="365" href="#365">365</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">void</strong> exceptionCaught(<a href="../../../../../org/apache/mina/common/IoFilter.html">NextFilter</a> nextFilter, <a href="../../../../../org/apache/mina/common/IoSession.html">IoSession</a> session,<a name="366" href="#366">366</a> Throwable cause) {<a name="367" href="#367">367</a> <strong class="jxr_keyword">if</strong> (eventTypes.contains(IoEventType.EXCEPTION_CAUGHT)) {<a name="368" href="#368">368</a> fireEvent(<strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/mina/common/IoFilterEvent.html">IoFilterEvent</a>(nextFilter,<a name="369" href="#369">369</a> IoEventType.EXCEPTION_CAUGHT, session, cause));<a name="370" href="#370">370</a> } <strong class="jxr_keyword">else</strong> {<a name="371" href="#371">371</a> nextFilter.exceptionCaught(session, cause);<a name="372" href="#372">372</a> }<a name="373" href="#373">373</a> }<a name="374" href="#374">374</a> <a name="375" href="#375">375</a> @Override<a name="376" href="#376">376</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">void</strong> messageReceived(<a href="../../../../../org/apache/mina/common/IoFilter.html">NextFilter</a> nextFilter, <a href="../../../../../org/apache/mina/common/IoSession.html">IoSession</a> session,<a name="377" href="#377">377</a> Object message) {<a name="378" href="#378">378</a> <strong class="jxr_keyword">if</strong> (eventTypes.contains(IoEventType.MESSAGE_RECEIVED)) {<a name="379" href="#379">379</a> fireEvent(<strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/mina/common/IoFilterEvent.html">IoFilterEvent</a>(nextFilter,<a name="380" href="#380">380</a> IoEventType.MESSAGE_RECEIVED, session, message));<a name="381" href="#381">381</a> } <strong class="jxr_keyword">else</strong> {<a name="382" href="#382">382</a> nextFilter.messageReceived(session, message);<a name="383" href="#383">383</a> }<a name="384" href="#384">384</a> }<a name="385" href="#385">385</a> <a name="386" href="#386">386</a> @Override<a name="387" href="#387">387</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">void</strong> messageSent(<a href="../../../../../org/apache/mina/common/IoFilter.html">NextFilter</a> nextFilter, <a href="../../../../../org/apache/mina/common/IoSession.html">IoSession</a> session,<a name="388" href="#388">388</a> <a href="../../../../../org/apache/mina/common/WriteRequest.html">WriteRequest</a> writeRequest) {<a name="389" href="#389">389</a> <strong class="jxr_keyword">if</strong> (eventTypes.contains(IoEventType.MESSAGE_SENT)) {<a name="390" href="#390">390</a> fireEvent(<strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/mina/common/IoFilterEvent.html">IoFilterEvent</a>(nextFilter, IoEventType.MESSAGE_SENT,<a name="391" href="#391">391</a> session, writeRequest));<a name="392" href="#392">392</a> } <strong class="jxr_keyword">else</strong> {<a name="393" href="#393">393</a> nextFilter.messageSent(session, writeRequest);<a name="394" href="#394">394</a> }<a name="395" href="#395">395</a> }<a name="396" href="#396">396</a> <a name="397" href="#397">397</a> @Override<a name="398" href="#398">398</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">void</strong> filterWrite(<a href="../../../../../org/apache/mina/common/IoFilter.html">NextFilter</a> nextFilter, <a href="../../../../../org/apache/mina/common/IoSession.html">IoSession</a> session,<a name="399" href="#399">399</a> <a href="../../../../../org/apache/mina/common/WriteRequest.html">WriteRequest</a> writeRequest) {<a name="400" href="#400">400</a> <strong class="jxr_keyword">if</strong> (eventTypes.contains(IoEventType.WRITE)) {<a name="401" href="#401">401</a> fireEvent(<strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/mina/common/IoFilterEvent.html">IoFilterEvent</a>(nextFilter, IoEventType.WRITE, session,<a name="402" href="#402">402</a> writeRequest));<a name="403" href="#403">403</a> } <strong class="jxr_keyword">else</strong> {<a name="404" href="#404">404</a> nextFilter.filterWrite(session, writeRequest);<a name="405" href="#405">405</a> }<a name="406" href="#406">406</a> }<a name="407" href="#407">407</a> <a name="408" href="#408">408</a> @Override<a name="409" href="#409">409</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">void</strong> filterClose(<a href="../../../../../org/apache/mina/common/IoFilter.html">NextFilter</a> nextFilter, <a href="../../../../../org/apache/mina/common/IoSession.html">IoSession</a> session)<a name="410" href="#410">410</a> <strong class="jxr_keyword">throws</strong> Exception {<a name="411" href="#411">411</a> <strong class="jxr_keyword">if</strong> (eventTypes.contains(IoEventType.CLOSE)) {<a name="412" href="#412">412</a> fireEvent(<strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/mina/common/IoFilterEvent.html">IoFilterEvent</a>(nextFilter, IoEventType.CLOSE, session,<a name="413" href="#413">413</a> <strong class="jxr_keyword">null</strong>));<a name="414" href="#414">414</a> } <strong class="jxr_keyword">else</strong> {<a name="415" href="#415">415</a> nextFilter.filterClose(session);<a name="416" href="#416">416</a> }<a name="417" href="#417">417</a> }<a name="418" href="#418">418</a> }</pre><hr/><div id="footer">This page was automatically generated by <a href="http://maven.apache.org/">Maven</a></div></body></html>
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -