Внедрение зависимостей не работает для @ClientEndpoint Java - PullRequest
Новая
       21

Внедрение зависимостей не работает для @ClientEndpoint Java

0 голосов
/ 15 ноября 2018

Есть ли способ включить cdi в этом классе @ClientEndpoint (все еще используя аннотации в отличие от программных классов конечных точек)? Я использую wildfly 14 и Java 8.

Вот код, который создает сеанс, передавая имя класса методу createConnection: 

@ApplicationScoped //TODO move this to be request scoped
public class SessionProducer {

@Produces
public Session getSession(InjectionPoint ip) {
        SessionAnnotation annotation = ip.getAnnotated().getAnnotation(SessionAnnotation.class);
        if(annotation != null) {
            Class clazz = annotation.clazz();
            String url = annotation.serverURL();
              WebSocketContainer webSocketContainer = ContainerProvider.getWebSocketContainer();
                try {
                    return webSocketContainer.connectToServer(clazz, new URI(url)); //<----------this is the line that uses the annotated class (clazz is a reference to the class)
                } catch (DeploymentException | IOException | URISyntaxException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
        }
        return null;    
    }   

/**
 * The destroy/disposer metho for the session
 * @param session
 */
public void close(@Disposes Session session) {

       try {
        session.close();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

    }
}

Вот аннотированный класс конечной точки: 

@ClientEndpoint
public class CryptoCompareWSClient {

@Inject
@CryptoCompare
private Event<String> cryptoCompareEvent; //<--------this is always null, no cdi happens

public CryptoCompareWSClient() {
    System.out.println("constructor");
    //cryptoCompareEvent = new Event();
}

@PostConstruct
public void init() {
    System.out.println("post construct"); //<---------this never gets called
}

@OnOpen
public void open(Session session) {
    //session.getAsyncRemote().sendText("SubAdd: { subs: ['0~Poloniex~BTC~USD'] }"  /*"test"*/);
    System.out.println("opened");
}


 @OnClose
public void close(Session session) {
    System.out.println("Session " + session + " closed");
}

 @OnError
 public void error(Throwable error) {
    System.out.println("Error: " + error.getMessage());
}

 @OnMessage
 public void message(String message, Session session) {
     System.out.println("Message");
     //cryptoCompareEvent.fireAsync(message);
 }
 }

Есть ли способ включить cdi в включенном классе?

Спасибо.

...