1 21 package org.jsmtpd.core.receive; 22 23 import java.io.IOException ; 24 import java.net.Socket ; 25 26 import org.jsmtpd.generic.threadpool.IThreadedClass; 27 28 33 public class ReceiverWorkerImpl implements IThreadedClass { 34 35 private ProtocolHandler proto = new ProtocolHandler(); 36 private Socket rec = null; 37 38 public void doJob() { 39 proto.init(rec); 40 } 41 42 public void forceShutdown() { 43 try { 44 if (rec != null) 45 rec.close(); 46 } catch (IOException e) { 47 48 } 49 } 50 51 public void gracefullShutdown() { 52 try { 53 if (rec != null) 54 rec.close(); 55 } catch (IOException e) { 56 57 } 58 } 59 60 public void setParam(Object o) { 61 rec = (Socket ) o; 62 } 63 64 } | Popular Tags |