2626import org .restlet .Context ;
2727import org .restlet .Request ;
2828import org .restlet .Response ;
29+ import org .restlet .Server ;
2930import org .restlet .data .ChallengeScheme ;
3031import org .restlet .data .Method ;
3132import org .restlet .data .Protocol ;
33+ import org .restlet .engine .connector .ConnectorHelper ;
3234import org .restlet .engine .io .IoUtils ;
3335import org .restlet .engine .log .LoggerFacade ;
3436
@@ -121,23 +123,18 @@ public static Thread createThreadWithLocalVariables(final Runnable runnable, Str
121123 final Integer currentVirtualHost = org .restlet .routing .VirtualHost .getCurrent ();
122124 final Response currentResponse = Response .getCurrent ();
123125
124- Runnable r =
125- new Runnable () {
126+ Runnable r = () -> {
127+ // Copy the thread local variables
128+ Response .setCurrent (currentResponse );
129+ Context .setCurrent (currentContext );
130+ org .restlet .routing .VirtualHost .setCurrent (currentVirtualHost );
131+ org .restlet .Application .setCurrent (currentApplication );
126132
127- @ Override
128- public void run () {
129- // Copy the thread local variables
130- Response .setCurrent (currentResponse );
131- Context .setCurrent (currentContext );
132- org .restlet .routing .VirtualHost .setCurrent (currentVirtualHost );
133- org .restlet .Application .setCurrent (currentApplication );
134-
135- try {
136- // Run the user task
137- runnable .run ();
138- } finally {
139- Engine .clearThreadLocalVariables ();
140- }
133+ try {
134+ // Run the user task
135+ runnable .run ();
136+ } finally {
137+ Engine .clearThreadLocalVariables ();
141138 }
142139 };
143140
@@ -385,7 +382,7 @@ public static void setRestletLogLevel(Level restletLogLevel) {
385382 private final List <org .restlet .engine .connector .ProtocolHelper > registeredProtocols ;
386383
387384 /** List of available server connectors. */
388- private final List <org . restlet . engine . connector . ConnectorHelper <org . restlet . Server >>
385+ private final List <ConnectorHelper <Server >>
389386 registeredServers ;
390387
391388 /** User class loader to use for dynamic class loading. */
@@ -529,26 +526,22 @@ public org.restlet.engine.connector.ConnectorHelper<Client> createHelper(
529526 * @return The new helper.
530527 */
531528 @ SuppressWarnings ("unchecked" )
532- public org .restlet .engine .connector .ConnectorHelper <org .restlet .Server > createHelper (
533- org .restlet .Server server , String helperClass ) {
534- org .restlet .engine .connector .ConnectorHelper <org .restlet .Server > result = null ;
529+ public ConnectorHelper <Server > createHelper (Server server , String helperClass ) {
530+ ConnectorHelper <Server > result = null ;
535531
536532 if (!server .getProtocols ().isEmpty ()) {
537- org .restlet .engine .connector .ConnectorHelper <org .restlet .Server > connector = null ;
538- for (final Iterator <org .restlet .engine .connector .ConnectorHelper <org .restlet .Server >>
539- iter = getRegisteredServers ().iterator ();
540- (result == null ) && iter .hasNext (); ) {
533+ ConnectorHelper <Server > connector = null ;
534+ for (final Iterator <ConnectorHelper <Server >> iter = getRegisteredServers ().iterator (); (result == null ) && iter .hasNext (); ) {
541535 connector = iter .next ();
542536
543- if ((helperClass == null )
544- || connector .getClass ().getCanonicalName ().equals (helperClass )) {
545- if (new HashSet <>(connector .getProtocols ())
546- .containsAll (server .getProtocols ())) {
537+ if (((helperClass == null )
538+ || connector .getClass ().getCanonicalName ().equals (helperClass ))
539+ && new HashSet <>(connector .getProtocols ()).containsAll (server .getProtocols ())) {
547540 try {
548541 result =
549542 connector
550543 .getClass ()
551- .getConstructor (org . restlet . Server .class )
544+ .getConstructor (Server .class )
552545 .newInstance (server );
553546 } catch (Exception e ) {
554547 Context .getCurrentLogger ()
@@ -558,7 +551,7 @@ public org.restlet.engine.connector.ConnectorHelper<org.restlet.Server> createHe
558551 e );
559552 }
560553 }
561- }
554+
562555 }
563556
564557 if (result == null ) {
@@ -600,7 +593,7 @@ private void discoverAuthenticators() throws IOException {
600593 */
601594 private void discoverConnectors () throws IOException {
602595 registerHelpers (DESCRIPTOR_CLIENT_PATH , getRegisteredClients (), Client .class );
603- registerHelpers (DESCRIPTOR_SERVER_PATH , getRegisteredServers (), org . restlet . Server .class );
596+ registerHelpers (DESCRIPTOR_SERVER_PATH , getRegisteredServers (), Server .class );
604597 registerDefaultConnectors ();
605598 }
606599
@@ -739,7 +732,7 @@ public List<org.restlet.engine.connector.ProtocolHelper> getRegisteredProtocols(
739732 *
740733 * @return The list of available server connectors.
741734 */
742- public List <org . restlet . engine . connector . ConnectorHelper <org . restlet . Server >>
735+ public List <ConnectorHelper <Server >>
743736 getRegisteredServers () {
744737 return this .registeredServers ;
745738 }
@@ -805,9 +798,9 @@ public void registerHelper(
805798 .getConstructor (constructorClass )
806799 .newInstance (constructorClass .cast (null )));
807800 }
808- } catch (Throwable t ) {
801+ } catch (Exception exception ) {
809802 Context .getCurrentLogger ()
810- .log (Level .INFO , "Unable to register the helper " + provider , t );
803+ .log (Level .INFO , "Unable to register the helper " + provider , exception );
811804 }
812805 }
813806 }
@@ -883,7 +876,9 @@ protected java.net.URLConnection openConnection(java.net.URL url)
883876 return new java .net .URLConnection (url ) {
884877
885878 @ Override
886- public void connect () throws IOException {}
879+ public void connect () {
880+ // no connection to open
881+ }
887882
888883 @ Override
889884 public InputStream getInputStream () throws IOException {
@@ -1010,7 +1005,7 @@ public void setRegisteredProtocols(
10101005 * @param registeredServers The list of available server helpers.
10111006 */
10121007 public void setRegisteredServers (
1013- List <org . restlet . engine . connector . ConnectorHelper <org . restlet . Server >>
1008+ List <ConnectorHelper <Server >>
10141009 registeredServers ) {
10151010 synchronized (this .registeredServers ) {
10161011 if (registeredServers != this .registeredServers ) {
0 commit comments