66import io .fabric8 .kubernetes .client .KubernetesClientException ;
77import io .fabric8 .kubernetes .api .model .EnvVar ;
88import java .util .logging .Logger ;
9+
10+ import com .sun .corba .se .spi .orbutil .fsm .Action ;
11+
912import java .net .InetAddress ;
1013import java .util .*;
1114
@@ -27,10 +30,13 @@ public void eventReceived(Action action, Pod resource) {
2730 logger .info ("labels: " +labels .toString ());
2831 if (!labels .containsKey ("dockerizedcraft/enabled" ) || !labels .get ("dockerizedcraft/enabled" ).equals ("true" )) return ;
2932
30- String dockerAction = "stop " ;
31- if (resource . getStatus ().getPhase (). equals ("Running " )){
33+ String dockerAction = "nothing " ;
34+ if (action . toString ().equals ("ADDED " )){
3235 dockerAction = "start" ;
3336 }
37+ else if (action .toString ().equals ("DELETED" )){
38+ dockerAction = "stop" ;
39+ }
3440
3541 ContainerEvent containerEvent = new ContainerEvent (resource .getMetadata ().getName (), dockerAction );
3642 containerEvent .setName (resource .getMetadata ().getName ());
@@ -43,7 +49,8 @@ public void eventReceived(Action action, Pod resource) {
4349 logger .info ("port: " +environmentVariables .get ("SERVER_PORT" ));
4450 containerEvent .setIp (InetAddress .getByName (resource .getStatus ().getPodIP ()));
4551 logger .info ("ip: " +resource .getStatus ().getPodIP ());
46- this .proxyServer .getPluginManager ().callEvent (containerEvent );
52+ if (!dockerAction .equals ("nothing" ))
53+ this .proxyServer .getPluginManager ().callEvent (containerEvent );
4754 }catch (java .net .UnknownHostException ex ){
4855 logger .severe (ex .getMessage ());
4956 }
0 commit comments