java - Closing socket when stopping Nifi costom processor -


i've been working @ custom nifi processor (extends abstractprocessor) pretty supposed same puttcp customized own server. receives flowfile , sends data content server through socket. using:

import java.net.socket;  newsocket = new socket(servername, port) newsocketout = newsocket.getoutputstream(); newsocketreader = new bufferedreader(newinputstreamreader(newsocket.getinputstream())); 

the problem when stop processor never triggers onunscheduled() or onstopped() leaves sockets unclosed since supposed close them. have onscheduled() works fine. ideas on how sockets close when stop processor or why onunscheduled() or onstopped() never triggers?


Comments

Popular posts from this blog

Is there a better way to structure post methods in Class Based Views -

performance - Why is XCHG reg, reg a 3 micro-op instruction on modern Intel architectures? -

jquery - Responsive Navbar with Sub Navbar -